You need to set a header with the key name
CamelIgniteCacheKey
See the IgniteConstants class for the headers
On Thu, Jun 8, 2017 at 12:52 PM, solomon <austin.solomon...@gmail.com> wrote:
> 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.
--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
