RouteBuilder subscriptionRouter()

in dynamic-router-eip/dynamic-router-eip-stack/main-router/src/main/java/org/apache/camel/example/springboot/numbers/mainrouter/config/MainRouterConfig.java [169:183]

15 lines of code
1 McCabe index (conditional complexity)


    RouteBuilder subscriptionRouter() {
        return new RouteBuilder(camelContext) {
            @Override
            public void configure() {
                from(subscribeUri)
                        .log(LoggingLevel.INFO, MainRouterConfig.class.getCanonicalName(), "Processing subscription: ${body}")
                        .unmarshal().json(DynamicRouterControlMessage.class)
                        .process(exchange -> {
                            Message<Events> message = MessageBuilder.withPayload(PARTICIPANT_SUBSCRIBED).build();
                            eventPublisher.publishEvent(new StateMachineEvent(this, message));
                        })
                        .to(COMPONENT_SCHEME_CONTROL + ":" + CONTROL_ACTION_SUBSCRIBE);
            }
        };
    }