Added clusterName option to Chronicle configuration to reflect the change in the API
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d994bcd6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d994bcd6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d994bcd6 Branch: refs/heads/mention Commit: d994bcd6ad6f6775093781a42fe0ebdfd79eab4d Parents: ed90ca5 Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue Feb 7 10:21:46 2017 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue Feb 7 10:21:46 2017 +0100 ---------------------------------------------------------------------- .../src/main/docs/chronicle-engine-component.adoc | 5 +++-- .../chronicle/engine/ChronicleEngineConfiguration.java | 13 +++++++++++++ .../chronicle/engine/ChronicleEngineProducer.java | 2 +- 3 files changed, 17 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d994bcd6/components/camel-chronicle/src/main/docs/chronicle-engine-component.adoc ---------------------------------------------------------------------- diff --git a/components/camel-chronicle/src/main/docs/chronicle-engine-component.adoc b/components/camel-chronicle/src/main/docs/chronicle-engine-component.adoc index e16d870..71cdc84 100644 --- a/components/camel-chronicle/src/main/docs/chronicle-engine-component.adoc +++ b/components/camel-chronicle/src/main/docs/chronicle-engine-component.adoc @@ -9,7 +9,7 @@ The Chronicle Engine component has no options. // endpoint options: START -The Chronicle Engine component supports 13 endpoint options which are listed below: +The Chronicle Engine component supports 14 endpoint options which are listed below: {% raw %} [width="100%",cols="2,1,1m,1m,5",options="header"] @@ -18,6 +18,7 @@ The Chronicle Engine component supports 13 endpoint options which are listed bel | addresses | common | | String | *Required* Engine addresses. Multiple addresses can be separated by comman. | path | common | | String | *Required* Engine path | action | common | | String | The default action to perform valid values are: - PUBLISH - PPUBLISH_AND_INDEX - PPUT - PGET_AND_PUT - PPUT_ALL - PPUT_IF_ABSENT - PGET - PGET_AND_REMOVE - PREMOVE - PIS_EMPTY - PSIZE +| clusterName | common | | String | Cluster name for queue | filteredMapEvents | common | | String | A comma separated list of Map event type to filer valid values are: INSERT UPDATE REMOVE. | persistent | common | true | boolean | Enable/disable data persistence | subscribeMapEvents | common | true | boolean | Set if consumer should subscribe to Map events default true. @@ -30,4 +31,4 @@ The Chronicle Engine component supports 13 endpoint options which are listed bel | synchronous | advanced | false | boolean | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported). |======================================================================= {% endraw %} -// endpoint options: END \ No newline at end of file +// endpoint options: END http://git-wip-us.apache.org/repos/asf/camel/blob/d994bcd6/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConfiguration.java b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConfiguration.java index 6b76ee9..ab56b95 100644 --- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConfiguration.java +++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConfiguration.java @@ -37,6 +37,8 @@ public class ChronicleEngineConfiguration { private String action; @UriParam(defaultValue = "true") private boolean persistent = true; + @UriParam + private String clusterName; // **************************** // CLIENT OPTIONS @@ -159,4 +161,15 @@ public class ChronicleEngineConfiguration { public void setPersistent(boolean persistent) { this.persistent = persistent; } + + public String getClusterName() { + return clusterName; + } + + /** + * Cluster name for queue + */ + public void setClusterName(String clusterName) { + this.clusterName = clusterName; + } } http://git-wip-us.apache.org/repos/asf/camel/blob/d994bcd6/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java index c8513d4..2c35823 100644 --- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java +++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java @@ -47,7 +47,7 @@ public class ChronicleEngineProducer extends HeaderSelectorProducer { this.topicPublisher = WeakRef.create(() -> client.acquireTopicPublisher(uri, Object.class, Object.class)); this.publisher = WeakRef.create(() -> client.acquirePublisher(uri, Object.class)); this.mapView = WeakRef.create(() -> client.acquireMap(uri, Object.class, Object.class)); - this.queueView = WeakRef.create(() -> client.acquireQueue(uri, Object.class, Object.class)); + this.queueView = WeakRef.create(() -> client.acquireQueue(uri, Object.class, Object.class, endpoint.getConfiguration().getClusterName())); } // ***************************
