ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From austin solomon <austin.solomon...@gmail.com>
Subject Using Camel-Ignite for inserting json object to Ignite's Cache
Date Thu, 08 Jun 2017 09:29:10 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://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.

Mime
View raw message