public void start()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceConnector.java [35:53]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    public void start(Map<String, String> props) {
        this.config = new TBConnectorConfig(config(), props);

        try (DXTickDB timebase = TickDBFactory.createFromUrl(config.getTBUrl(), config.getTBUser(), config.getTBPassword())) {
            timebase.open(true);

            DXTickStream msgStream = timebase.getStream(config.getTBStream());
            if (msgStream == null) {
                throw new IllegalArgumentException(config.getTBStream() + " timebase stream does not exist");
            }

            //DataField field = msgStream.getFixedType().getField(tbMessageId);
            //if (field == null) {
            //    throw new IllegalArgumentException(tbMessageId + " field does not exist in timebase stream " + tbStream);
            //}

            //if allow multiple streams and using a filter, monitor TB stream spaces and reassign tasks when new space is added
        }
    }