ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From austin solomon <austin.solomon...@gmail.com>
Subject Re: Using Camel-Ignite for inserting json object to Ignite's Cache
Date Fri, 09 Jun 2017 13:27:58 GMT
Hi Val,

I'm just playing around with Camel-Ignite component for a POC. my goal is to
parse the JSON data and put it to Ignite's cache.

I got the syntax from Camel-Ignite component's test project [1]

After some changes in my code now the data is inserting into the Ignite's
cache (by checking the entries in Ignite Visor) but when querying the result
is showing empty.

Here is the code: 
from("mqtt:bar?subscribeTopicName=test&host=tcp://10.10.1.34:1883")
	.setHeader("id", new JsonPathExpression("$.id")) 
	.setHeader("firstName", new JsonPathExpression("$.firstName"))
	.setHeader(IgniteConstants.IGNITE_CACHE_KEY, new
JsonPathExpression("$.id"))
        .process(new Processor() {
		public void process(Exchange exchange)throws Exception {
				exchange.getIn().setBody( exchange.getIn().getBody(String.class));
                }
	})
        .to("ignite-cache:cache:Person?operation=PUT");

What am I missing?

[1]
https://github.com/apache/camel/blob/master/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteCacheTest.java




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

Mime
View raw message