You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/08/28 13:23:50 UTC
[3/3] camel git commit: Camel-Hazelcast Kubernetes example: removed
deprecated method usage
Camel-Hazelcast Kubernetes example: removed deprecated method usage
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f677e2dd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f677e2dd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f677e2dd
Branch: refs/heads/master
Commit: f677e2dd031151bb52b43ec8bbb62e4a0d4a28ed
Parents: 7faa4f4
Author: Andrea Cosentino <an...@gmail.com>
Authored: Mon Aug 28 15:21:59 2017 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Mon Aug 28 15:21:59 2017 +0200
----------------------------------------------------------------------
.../org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f677e2dd/examples/camel-example-hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java b/examples/camel-example-hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java
index b098513..f18781d 100644
--- a/examples/camel-example-hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java
+++ b/examples/camel-example-hazelcast-kubernetes/src/main/java/org/apache/camel/example/kubernetes/fmp/HazelcastRoute.java
@@ -27,6 +27,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.hazelcast.HazelcastConstants;
+import org.apache.camel.component.hazelcast.HazelcastOperation;
import org.apache.camel.component.hazelcast.topic.HazelcastTopicComponent;
public class HazelcastRoute extends RouteBuilder {
@@ -50,7 +51,7 @@ public class HazelcastRoute extends RouteBuilder {
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HazelcastConstants.OPERATION, HazelcastConstants.PUBLISH_OPERATION);
+ exchange.getIn().setHeader(HazelcastConstants.OPERATION, HazelcastOperation.PUBLISH);
String payload = "Test " + UUID.randomUUID();
exchange.getIn().setBody(payload);
}