private void send()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [124:137]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    private void send(RawMessage message) {
        if (tbLoader == null) {
            if (msgStream == null) {
                String tbStream = config.getTBStream();
                StreamOptions options = new StreamOptions(StreamScope.DURABLE, tbStream, "Created by TBSinkConnector", StreamOptions.MAX_DISTRIBUTION);
                options.setFixedType(message.type);
                msgStream = timebase.createStream(tbStream, options);
            }
            LoadingOptions options = new LoadingOptions(true);
            options.writeMode = LoadingOptions.WriteMode.APPEND;
            tbLoader = msgStream.createLoader(options);
        }
        tbLoader.send(message);
    }