Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for https://issues.apache.org/activemq/browse/AMQ-2025 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@723614 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-12-05 06:44:41 +00:00
parent d7f34d9a6f
commit 0cf2cdc719
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.jms.JMSException;
@ -45,6 +46,7 @@ public class ActiveMQSessionExecutor implements Task {
private boolean dispatchedBySessionPool;
private TaskRunner taskRunner;
private boolean startedOrWarnedThatNotStarted;
private AtomicBoolean taskRunnerCreated = new AtomicBoolean();
ActiveMQSessionExecutor(ActiveMQSession session) {
this.session = session;
@ -88,15 +90,18 @@ public class ActiveMQSessionExecutor implements Task {
if (!dispatchedBySessionPool) {
if (session.isSessionAsyncDispatch()) {
try {
if (taskRunner == null) {
taskRunner = session.connection.getSessionTaskRunner().createTaskRunner(this, "ActiveMQ Session: " + session.getSessionId());
if (taskRunnerCreated.compareAndSet(false, true)) {
if (taskRunner == null) {
taskRunner = session.connection.getSessionTaskRunner().createTaskRunner(this,
"ActiveMQ Session: " + session.getSessionId());
}
}
taskRunner.wakeup();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
} else {
while (iterate()) {
while (iterate()) {
}
}
}
@ -141,6 +146,7 @@ public class ActiveMQSessionExecutor implements Task {
if (taskRunner != null) {
taskRunner.shutdown();
taskRunner = null;
taskRunnerCreated.set(false);
}
}
} catch (InterruptedException e) {