public void start()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkConnector.java [29:40]

• 10 lines of code
• 3 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(false);

            DXTickStream msgStream = timebase.getStream(config.getTBStream());
            if (msgStream != null && msgStream.isPolymorphic()) {
                throw new IllegalArgumentException(msgStream.getName() + " is a polymorphic timebase stream");
            }
        }
    }