Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-27 12:55:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/activemq/browse/AMQ-1078

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.1@480862 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-11-30 07:19:19 +00:00
parent 11266b8df4
commit 5bb32abe03
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,8 +63,11 @@ public class ActiveMQSessionExecutor implements Task {
public void wakeup() { public void wakeup() {
if( !dispatchedBySessionPool ) { if( !dispatchedBySessionPool ) {
if( taskRunner!=null ) { if( session.isSessionAsyncDispatch() ) {
try { try {
if( taskRunner == null ) {
taskRunner = session.connection.getSessionTaskRunner().createTaskRunner(this, "ActiveMQ Session: "+session.getSessionId());
}
taskRunner.wakeup(); taskRunner.wakeup();
} catch (InterruptedException e) { } catch (InterruptedException e) {
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
@ -101,9 +104,7 @@ public class ActiveMQSessionExecutor implements Task {
synchronized void start() { synchronized void start() {
if( !messageQueue.isRunning() ) { if( !messageQueue.isRunning() ) {
messageQueue.start(); messageQueue.start();
if( session.isSessionAsyncDispatch() || dispatchedBySessionPool ) { if( hasUncomsumedMessages() )
taskRunner = session.connection.getSessionTaskRunner().createTaskRunner(this, "ActiveMQ Session: "+session.getSessionId());
}
wakeup(); wakeup();
} }
} }