protected void initTimeBaseStream()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamReplicationServiceTest.java [70:99]

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

    protected void initTimeBaseStream() {
        DXTickDB tbConnection = connectionService.getConnection();
        connectionService.init(false);

        Introspector introspector = Introspector.createEmptyMessageIntrospector();

        RecordClassDescriptor[] recordClassDescriptors = new RecordClassDescriptor[2];
        try {
            RecordClassDescriptor firstRecordClassDescriptor = introspector.introspectRecordClass(FirstTestClass.class);
            RecordClassDescriptor secondRecordClassDescriptor = introspector.introspectRecordClass(SecondTestClass.class);
            recordClassDescriptors[0] = firstRecordClassDescriptor;
            recordClassDescriptors[1] = secondRecordClassDescriptor;
        } catch (Introspector.IntrospectionException ex) {
            ex.printStackTrace();
        }

        StreamOptions streamOptions = new StreamOptions();
        streamOptions.setPolymorphic(recordClassDescriptors);

        DXTickStream someStream = tbConnection.createStream("someStreamName", streamOptions);

        LoadingOptions loadingOptions = new LoadingOptions(LoadingOptions.WriteMode.APPEND);
        TickLoader loader = someStream.createLoader(loadingOptions);

        List<BaseTestClass> entities = getTimeBaseEntities();

        entities.forEach(entity -> loader.send(entity));

        loader.close();
    }