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: Camel-Ignite cache query : Could not find a suitable setter for property: query
Date Thu, 29 Jun 2017 14:20:07 GMT
Hi Evgenii,

As you said I did not had registry bean in my context. I have created a
SimpleRegistry using the code below.

SimpleRegistry registry = new SimpleRegistry();
        ScanQuery<Integer, Temperature> query = new ScanQuery<>(new
IgniteBiPredicate<Integer, Temperature>() {
            private static final long serialVersionUID = 1L;

			public boolean apply(Integer key, Temperature temperature) {
				return temperature.getId() < 50;
        registry.put("query", query);
	builder.registryFactory(createOsgiRegistry(ctx, registry));

private static final class IgniteRouteBuilder extends RouteBuilder {
            public void configure() throws Exception {
    			.process(new MyLogProcessor())

But now the Error is gone, however I'm not getting the query result.

In the console I'm getting the follwing output:

[AllowUseOriginalMessage is enabled. If access to the original message is
not needed, then its recommended to turn this option off as it may improve
[StreamCaching is not in use. If using streams then its recommended to
enable stream caching. See more details at
[Started Ignite Cache Continuous Query consumer for cache temperature with
query: ScanQuery
Skipping existing cache results for cache name = temperature.]
Route: route1 started and consuming from:
Total 1 routes, of which 1 are started.
Apache Camel 2.17.2 (CamelContext: camel-3) started in 3.989 seconds

What am I missing here?

View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Camel-Ignite-cache-query-Could-not-find-a-suitable-setter-for-property-query-tp14128p14165.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

View raw message