Adding a check if the hazelcastInstanceName parameter is present or not before querying the cluster.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ee5c0f86 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ee5c0f86 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ee5c0f86 Branch: refs/heads/master Commit: ee5c0f86b30abe88a8f783f6db7751a9cc99bec0 Parents: c44f797 Author: Ayache Khettar <aya...@zotix-consulting.co.uk> Authored: Wed Mar 25 11:27:39 2015 +0000 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Mar 25 15:03:01 2015 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/hazelcast/HazelcastComponent.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ee5c0f86/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponent.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponent.java index eb752dd..d7153f7 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponent.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponent.java @@ -177,7 +177,7 @@ public class HazelcastComponent extends UriEndpointComponent { HazelcastInstance.class); // check if an already created instance is given then just get instance by its name. - if (hzInstance == null) + if (hzInstance == null && parameters.get(HAZELCAST_INSTANCE_NAME_PARAM) != null) { hzInstance = Hazelcast.getHazelcastInstanceByName((String) parameters.get(HAZELCAST_INSTANCE_NAME_PARAM)); parameters.remove(HAZELCAST_INSTANCE_NAME_PARAM);
