protected void subscribe()

in dynamic-router-eip/dynamic-router-eip-stack/numbers-common/src/main/java/org/apache/camel/example/springboot/numbers/common/service/RoutingParticipant.java [113:122]

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

    protected void subscribe() {
        try {
            DynamicRouterControlMessage message = createSubscribeMessage();
            String messageJson = objectMapper.writeValueAsString(message);
            LOG.info("Sending subscribe message: {} to {}", messageJson, subscribeUri);
            producerTemplate.sendBody(subscribeUri, messageJson);
        } catch (Exception e) {
            throw new IllegalStateException("Could not serialize a message", e);
        }
    }