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 2017/01/09 13:00:47 UTC
[2/2] camel git commit: CAMEL-10677: And use submit for the consumer
task as it should not risk using the starter thread which execute can do.
CAMEL-10677: And use submit for the consumer task as it should not risk using the starter thread which execute can do.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5eb6868f
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5eb6868f
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5eb6868f
Branch: refs/heads/camel-2.18.x
Commit: 5eb6868f62dfb7eadfeb85ccb77f9d02e70fd606
Parents: 28f4bfe
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Jan 9 14:00:38 2017 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Jan 9 14:00:38 2017 +0100
----------------------------------------------------------------------
.../org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/5eb6868f/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java
index 243c2b8..b17cba7 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java
@@ -74,7 +74,7 @@ public class SjmsBatchConsumer extends DefaultConsumer {
private ExecutorService jmsConsumerExecutors;
private final AtomicBoolean running = new AtomicBoolean(true);
private final AtomicReference<CountDownLatch> consumersShutdownLatchRef = new AtomicReference<>();
- private Connection connection;
+ private volatile Connection connection;
public SjmsBatchConsumer(SjmsBatchEndpoint sjmsBatchEndpoint, Processor processor) {
super(sjmsBatchEndpoint, processor);
@@ -144,7 +144,7 @@ public class SjmsBatchConsumer extends DefaultConsumer {
for (int i = 0; i < consumerCount; i++) {
BatchConsumptionLoop loop = new BatchConsumptionLoop();
triggers.add(loop.getCompletionTimeoutTrigger());
- jmsConsumerExecutors.execute(loop);
+ jmsConsumerExecutors.submit(loop);
}
if (completionInterval > 0) {