Using Camel-Ignite for inserting json object to Ignite's Cache

[austin solomon]

Hi,

I'm trying to listen from an mqtt topic which produces a json object and
store that data into apache Ignite's Cache using Apache camel contex, but
the data is not inserting to cache.

my JSON data looks like this : {"id": 1, "data":"test"}

and this is sample code snippet : 

         from("mqtt:bar?subscribeTopicName=test&host=tcp://localhost:1883")
        .setHeader("id", new JsonPathExpression("$.id")) 
        .setHeader("data", new JsonPathExpression("$.data"))
        .process(new Processor() {
                public void process(Exchange exchange)throws Exception {
                         exchange.getIn().setBody(
exchange.getIn().getBody(String.class));
                         System.out.println("Processing JSON Meassage: "+
exchange.getIn().getBody(String.class));
                }
        })
        .to("ignite-cache:cache:myCacheName?operation=PUT");

Can anyone help me what I am missing.

How to insert the Key-Value into Ignite's cache and query it later.








--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Using-Camel-Ignite-for-inserting-json-object-to-Ignite-s-Cache-tp13513.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.