Refine the Camel example with Infinispan Spring-Boot starter

Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4781c40a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4781c40a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4781c40a

Branch: refs/heads/master
Commit: 4781c40ac9bd816271918081c04aeae59b73b831
Parents: 87147fc
Author: Andrea Cosentino <anco...@gmail.com>
Authored: Thu Aug 3 11:13:56 2017 +0200
Committer: Andrea Cosentino <anco...@gmail.com>
Committed: Thu Aug 3 11:21:34 2017 +0200

----------------------------------------------------------------------
 .../infinispan/CamelInfinispanRoute.java          | 18 ++----------------
 .../src/main/resources/application.properties     |  1 +
 2 files changed, 3 insertions(+), 16 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/4781c40a/examples/camel-example-spring-boot-infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
----------------------------------------------------------------------
diff --git 
a/examples/camel-example-spring-boot-infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
 
b/examples/camel-example-spring-boot-infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
index a7f519b..4cd9d5a 100644
--- 
a/examples/camel-example-spring-boot-infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
+++ 
b/examples/camel-example-spring-boot-infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
@@ -16,14 +16,9 @@
  */
 package org.apache.camel.example.springboot.infinispan;
 
-import java.io.IOException;
-
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.infinispan.InfinispanConstants;
 import org.apache.camel.component.infinispan.InfinispanOperation;
-import org.infinispan.client.hotrod.RemoteCacheManager;
-import org.infinispan.client.hotrod.configuration.ConfigurationBuilder;
-import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 
 /**
@@ -38,19 +33,10 @@ public class CamelInfinispanRoute extends RouteBuilder {
         
.setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT)
         .setHeader(InfinispanConstants.KEY).constant("1")
         .setHeader(InfinispanConstants.VALUE).constant("test")
-        .to("infinispan://default?cacheContainer=#cacheContainer")
+        .to("infinispan://default")
         
.setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
         .setHeader(InfinispanConstants.KEY).constant("1")
-        
.to("infinispan://default?cacheContainer=#cacheContainer").log("Received body: 
${body}");
-
-    }
-    
-    @Bean(name = "cacheContainer")
-    public RemoteCacheManager remoteCacheManager() throws IOException {
-        ConfigurationBuilder builder = new ConfigurationBuilder();
-        builder.addServer().host("localhost")
-              .port(11222);
-        return new RemoteCacheManager(builder.build());
+        .to("infinispan://default").log("Received body: ${body}");
     }
 
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/4781c40a/examples/camel-example-spring-boot-infinispan/src/main/resources/application.properties
----------------------------------------------------------------------
diff --git 
a/examples/camel-example-spring-boot-infinispan/src/main/resources/application.properties
 
b/examples/camel-example-spring-boot-infinispan/src/main/resources/application.properties
index bfa2883..7a406ce 100644
--- 
a/examples/camel-example-spring-boot-infinispan/src/main/resources/application.properties
+++ 
b/examples/camel-example-spring-boot-infinispan/src/main/resources/application.properties
@@ -17,4 +17,5 @@
 
 camel.springboot.name=Infinispan
 camel.springboot.main-run-controller=true
+camel.component.infinispan.configuration.hosts=localhost:11222
 

Reply via email to