camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From solomon <austin.solomon...@gmail.com>
Subject Re: Apache-Ignite Example
Date Thu, 08 Jun 2017 10:52:31 GMT
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://camel.465427.n5.nabble.com/Apache-Ignite-Example-tp5800977p5802573.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message