From 7ad152bac8bbdef1aa36f064683018701cf24e82 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Tue, 22 Jun 2010 20:08:12 +0000 Subject: [PATCH] Ensure executor constructed correctly git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@957005 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/activemq/ActiveMQSession.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java index 8883808268..504d708403 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java @@ -206,7 +206,7 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta protected final LongSequenceGenerator consumerIdGenerator = new LongSequenceGenerator(); protected final LongSequenceGenerator producerIdGenerator = new LongSequenceGenerator(); protected final LongSequenceGenerator deliveryIdGenerator = new LongSequenceGenerator(); - protected final ActiveMQSessionExecutor executor = new ActiveMQSessionExecutor(this); + protected final ActiveMQSessionExecutor executor; protected final AtomicBoolean started = new AtomicBoolean(false); protected final CopyOnWriteArrayList consumers = new CopyOnWriteArrayList(); @@ -253,6 +253,7 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta setBlobTransferPolicy(connection.getBlobTransferPolicy()); this.scheduler=connection.getScheduler(); this.connectionExecutor=connection.getExecutor(); + this.executor = new ActiveMQSessionExecutor(this); if (connection.isStarted()) { start(); }