public void handleNewStreamEvent()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/ApplicationEventHandler.java [118:131]

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

    public void handleNewStreamEvent(NewStreamEvent event) {
        String streamName = (String) event.getSource();
        LOG.info().append("Received NewStreamEvent for stream: ").append(streamName).commit();

        boolean isMatched = streamWildcards.stream()
                .filter(wildcard -> streamName.matches(wildcard))
                .findAny()
                .isPresent();

        if (isMatched) {
            cacheService.add(streamName, new StreamMetaData(StreamMetaData.Status.RUNNING));
            executor.execute(() -> replicationService.replicate(streamName));
        }
    }