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.
