I dont know what data type mqtt gives you, you can turn on tracer to
see that etc.
But you can also try to convert the data to a String.class before via
.convertBodyTo(String.class) assuming Ignite can store plain strings
and get them again via query.
On Fri, Jun 9, 2017 at 3:34 PM, solomon wrote
Hi Claus & Gary,
I have set the header as .setHeader(IgniteConstants.IGNITE_CACHE_KEY, new
JsonPathExpression("$.id"))
now the data is getting inserted, when I checked the node entry in Ignite
visor console count increases when message comes from the mqtt channel.
However while querying the cache
Hey solomon, perhaps the following example helps?
public class ExampleIgniteCacheTest extends CamelTestSupport {
@EndpointInject(uri = "mock:result")
protected MockEndpoint resultEndpoint;
@Test
public void testCache() throws Exception {
String e
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 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 Apach
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(
See the camel-ignite documentation and the unit tests of itself to
find examples. You need to configure the camel ignite component with
some cache configuration.
On Sat, May 27, 2017 at 10:05 AM, solomon wrote:
> Hi Claus,
>
> I started the CamelContext, now getting the following exception
>
> Ca
Hi Claus,
I started the CamelContext, now getting the following exception
Caused by: java.lang.IllegalStateException: No configuration resource or
IgniteConfiguration was provided to the Ignite component.
at
org.apache.camel.component.ignite.IgniteComponent.doStart(IgniteComponent.java:17
You need to start CamelContext at least
On Sat, May 27, 2017 at 8:24 AM, solomon wrote:
> Hi,
>
> I'm trying to run a camel program which gets the data from camel-mqtt
> component and insert the data into camel-ignite-cache, however the data is
> not inserting into Ignite's cache. There is no any
