You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/05/05 06:58:48 UTC
camel git commit: Allow to configure on component level also and
expose in JMX.
Repository: camel
Updated Branches:
refs/heads/master d93f8c0e4 -> b3783a536
Allow to configure on component level also and expose in JMX.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b3783a53
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b3783a53
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b3783a53
Branch: refs/heads/master
Commit: b3783a536ad0220b03f1b3f712f5f1e5887c6c9d
Parents: d93f8c0
Author: Claus Ibsen <da...@apache.org>
Authored: Thu May 5 08:58:24 2016 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu May 5 08:58:24 2016 +0200
----------------------------------------------------------------------
components/camel-jms/src/main/docs/jms.adoc | 6 ++++-
.../camel/component/jms/JmsComponent.java | 23 ++++++++++++++++++++
.../apache/camel/component/jms/JmsEndpoint.java | 20 +++++++++++++++++
3 files changed, 48 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b3783a53/components/camel-jms/src/main/docs/jms.adoc
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/docs/jms.adoc b/components/camel-jms/src/main/docs/jms.adoc
index eb4effa..8efed5c 100644
--- a/components/camel-jms/src/main/docs/jms.adoc
+++ b/components/camel-jms/src/main/docs/jms.adoc
@@ -208,8 +208,9 @@ Component options
+
// component options: START
-The JMS component supports 69 options which are listed below.
+The JMS component supports 71 options which are listed below.
@@ -285,11 +286,14 @@ The JMS component supports 69 options which are listed below.
| queueBrowseStrategy | QueueBrowseStrategy | To use a custom QueueBrowseStrategy when browsing queues
| headerFilterStrategy | HeaderFilterStrategy | To use a custom HeaderFilterStrategy to filter header to and from Camel message.
| messageCreatedStrategy | MessageCreatedStrategy | To use the given MessageCreatedStrategy which are invoked when Camel creates new instances of javax.jms.Message objects when Camel is sending a JMS message.
+| waitForProvisionCorrelationToBeUpdatedCounter | int | Number of times to wait for provisional correlation id to be updated to the actual correlation id when doing request/reply over JMS and when the option useMessageIDAsCorrelationID is enabled.
+| waitForProvisionCorrelationToBeUpdatedThreadSleepingTime | long | Interval in millis to sleep each time while waiting for provisional correlation id to be updated.
|=======================================================================
// component options: END
+
[[JMS-Endpointoptions]]
Endpoint options
++++++++++++++++
http://git-wip-us.apache.org/repos/asf/camel/blob/b3783a53/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
index 4ff90e9..8553688 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
@@ -793,6 +793,29 @@ public class JmsComponent extends UriEndpointComponent implements ApplicationCon
this.messageCreatedStrategy = messageCreatedStrategy;
}
+ public int getWaitForProvisionCorrelationToBeUpdatedCounter() {
+ return getConfiguration().getWaitForProvisionCorrelationToBeUpdatedCounter();
+ }
+
+ /**
+ * Number of times to wait for provisional correlation id to be updated to the actual correlation id when doing request/reply over JMS
+ * and when the option useMessageIDAsCorrelationID is enabled.
+ */
+ public void setWaitForProvisionCorrelationToBeUpdatedCounter(int counter) {
+ getConfiguration().setWaitForProvisionCorrelationToBeUpdatedCounter(counter);
+ }
+
+ public long getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime() {
+ return getConfiguration().getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime();
+ }
+
+ /**
+ * Interval in millis to sleep each time while waiting for provisional correlation id to be updated.
+ */
+ public void setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(long sleepingTime) {
+ getConfiguration().setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(sleepingTime);
+ }
+
// Implementation methods
// -------------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b3783a53/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
index c6a3599..6804470 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
@@ -1257,6 +1257,26 @@ public class JmsEndpoint extends DefaultEndpoint implements AsyncEndpoint, Heade
configuration.setSelector(selector);
}
+ @ManagedAttribute
+ public int getWaitForProvisionCorrelationToBeUpdatedCounter() {
+ return configuration.getWaitForProvisionCorrelationToBeUpdatedCounter();
+ }
+
+ @ManagedAttribute
+ public void setWaitForProvisionCorrelationToBeUpdatedCounter(int counter) {
+ configuration.setWaitForProvisionCorrelationToBeUpdatedCounter(counter);
+ }
+
+ @ManagedAttribute
+ public long getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime() {
+ return configuration.getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime();
+ }
+
+ @ManagedAttribute
+ public void setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(long sleepingTime) {
+ configuration.setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(sleepingTime);
+ }
+
// Implementation methods
//-------------------------------------------------------------------------