activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r494331 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
Date Tue, 09 Jan 2007 06:51:18 GMT
Author: rajdavies
Date: Mon Jan  8 22:51:17 2007
New Revision: 494331

URL: http://svn.apache.org/viewvc?view=rev&rev=494331
Log:
ignoring the mutex for shutdown causes sporadic failures in open-wire

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=494331&r1=494330&r2=494331
==============================================================================
--- 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
Mon Jan  8 22:51:17 2007
@@ -40,12 +40,8 @@
     }
 
     public void oneway(Object command) throws IOException{
-        if(command instanceof ShutdownInfo){
+        synchronized(writeMutex){
             next.oneway(command);
-        }else{
-            synchronized(writeMutex){
-                next.oneway(command);
-            }
         }
     }
 



Mime
View raw message