activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject svn commit: r493644 - /incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
Date Sun, 07 Jan 2007 04:42:07 GMT
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);
         }
     }
 



Mime
View raw message