public void configure()

in hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java [35:61]

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

    public void configure() throws Exception {
        // setup hazelcast
        ClientConfig config = new ClientConfig();
        config.getNetworkConfig().addAddress("hazelcast");
        config.getNetworkConfig().setSSLConfig(new SSLConfig().setEnabled(false));
        HazelcastInstance instance = HazelcastClient.newHazelcastClient(config);

        // setup camel hazelcast
        HazelcastTopicComponent hazelcast = new HazelcastTopicComponent();
        hazelcast.setHazelcastInstance(instance);
        getContext().addComponent("hazelcast-topic", hazelcast);

        from("timer:foo?period=5000")
            .log("Producer side: Sending data to Hazelcast topic..")
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    exchange.getIn().setHeader(HazelcastConstants.OPERATION, HazelcastOperation.PUBLISH);
                    String payload = "Test " + UUID.randomUUID();
                    exchange.getIn().setBody(payload);
                }
            })
            .to("hazelcast-topic:foo");

        from("hazelcast-topic:foo")
            .log("Consumer side: Detected following action: $simple{in.header.CamelHazelcastListenerAction}");
    }