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

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 : 

	.setHeader("id", new JsonPathExpression("$.id")) 
	.setHeader("data", new JsonPathExpression("$.data"))
        .process(new Processor() {
		public void process(Exchange exchange)throws Exception {
		         System.out.println("Processing JSON Meassage: "+

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.

View raw message