diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java index a2be8057e4..7c33df2e81 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java @@ -40,12 +40,8 @@ public class MutexTransport extends TransportFilter { } public void oneway(Object command) throws IOException{ - if(command instanceof ShutdownInfo){ + synchronized(writeMutex){ next.oneway(command); - }else{ - synchronized(writeMutex){ - next.oneway(command); - } } }