camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [19/24] camel git commit: Added clusterName option to Chronicle configuration to reflect the change in the API
Date Tue, 07 Feb 2017 13:07:43 GMT
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 <ancosen@gmail.com>
Authored: Tue Feb 7 10:21:46 2017 +0100
Committer: Andrea Cosentino <ancosen@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()));
     }
 
     // ***************************


Mime
View raw message