svn commit: r493573 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java

[rajdavies]

Author: rajdavies
Date: Sat Jan  6 13:15:01 2007
New Revision: 493573

URL: http://svn.apache.org/viewvc?view=rev&rev=493573
Log:
 fix for http://issues.apache.org/activemq/browse/AMQ-1119

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java?view=diff&rev=493573&r1=493572&r2=493573
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
 Sat Jan  6 13:15:01 2007
@@ -18,6 +18,7 @@
 package org.apache.activemq.transport;
 
 import java.io.IOException;
+import org.apache.activemq.command.ShutdownInfo;
 
 
 
@@ -38,9 +39,13 @@
         }
     }
 
-    public void oneway(Object command) throws IOException {
-        synchronized(writeMutex) {
+    public void oneway(Object command) throws IOException{
+        if(command instanceof ShutdownInfo){
             next.oneway(command);
+        }else{
+            synchronized(writeMutex){
+                next.oneway(command);
+            }
         }
     }