You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jl...@apache.org on 2007/01/07 05:42:07 UTC
svn commit: r493644 -
/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
Author: jlim
Date: Sat Jan 6 20:42:06 2007
New Revision: 493644
URL: http://svn.apache.org/viewvc?view=rev&rev=493644
Log:
applied fix for http://issues.apache.org/activemq/browse/AMQ-1119
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java?view=diff&rev=493644&r1=493643&r2=493644
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java Sat Jan 6 20:42:06 2007
@@ -18,6 +18,7 @@
package org.apache.activemq.transport;
import java.io.IOException;
+import org.apache.activemq.command.ShutdownInfo;
import org.apache.activemq.command.Command;
import org.apache.activemq.command.Response;
@@ -40,9 +41,14 @@
}
}
- public void oneway(Command command) throws IOException {
- synchronized(writeMutex) {
- next.oneway(command);
+ public void oneway(Object command) throws IOException{
+ if(command instanceof ShutdownInfo){
+ next.oneway((Command)command);
+ }else{
+ synchronized(writeMutex){
+ next.oneway((Command)command);
+ }
+ next.oneway((Command)command);
}
}