You need to start CamelContext at least
On Sat, May 27, 2017 at 8:24 AM, solomon <austin.solomon...@gmail.com> 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 errors while running
> this.
>
> I searched for camel-ignite example online but didn't get any.
>
> My code snippet is like this
>
> Ignite ignite = Ignition.start("examples/config/example-ignite.xml");
>
> CacheConfiguration<Integer, String> cfg = new
> CacheConfiguration<>();
> cfg.setCacheMode(CacheMode.PARTITIONED);
>
> IgniteCache<Integer, String> cache =
> ignite.getOrCreateCache("myCacheName");
>
> IgniteDataStreamer<String, String> pipe =
> ignite.dataStreamer("myCacheName");
>
> CamelStreamer<String, String> streamer = new
> CamelStreamer<>();
> streamer.setIgnite(ignite);
> streamer.setStreamer(pipe);
>
> CamelContext context = new DefaultCamelContext();
> try {
> context.addRoutes(new RouteBuilder() {
> @Override
> public void configure() throws Exception {
>
> from("mqtt:bar?subscribeTopicName=test&host=tcp://localhost:1883")
> .to("ignite-cache:myCacheName?operation=PUT",
> "1234",
> IgniteConstants.IGNITE_CACHE_KEY, "abcd");
> }
> });
> } catch (Exception e) {
> e.printStackTrace();
> }
>
> streamer.setEndpointUri("ignite-cache:myCacheName?operation=PUT");
>
>
> Can any one guide me on how to ingest data into Ignite's cache.
>
> Thanks
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Apache-Ignite-Example-tp5800977.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
