From 43fb483c3344afd9ddb75d104aeaae9e15acbd5a Mon Sep 17 00:00:00 2001 From: "Jonas B. Lim" Date: Sun, 7 Jan 2007 04:42:06 +0000 Subject: [PATCH] applied fix for http://issues.apache.org/activemq/browse/AMQ-1119 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.0@493644 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/transport/MutexTransport.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) 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 3c3d6dec3f..dce8c7d927 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 @@ -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 class MutexTransport extends TransportFilter { } } - 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); } }