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 <davscl...@apache.org> Authored: Thu May 5 08:58:24 2016 +0200 Committer: Claus Ibsen <davscl...@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 //-------------------------------------------------------------------------
