camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject camel git commit: Allow to configure on component level also and expose in JMX.
Date Thu, 05 May 2016 06:58:48 GMT
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 <davsclaus@apache.org>
Authored: Thu May 5 08:58:24 2016 +0200
Committer: Claus Ibsen <davsclaus@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
     //-------------------------------------------------------------------------
 


Mime
View raw message