Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
Date: Fri, 9 Jun 2017 06:27:58 -0700 (MST)
From: austin solomon <austin.solomon007@gmail.com>
To: user@ignite.apache.org
Message-ID: <1497014878626-13568.post@n6.nabble.com>
In-Reply-To: <1496964523393-13539.post@n6.nabble.com>
References: <1496914150067-13513.post@n6.nabble.com> <1496964523393-13539.post@n6.nabble.com>
Subject: Re: Using Camel-Ignite for inserting json object to Ignite's Cache
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
archived-at: Fri, 09 Jun 2017 13:28:03 -0000

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.