mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493573 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
8e8b82024b
commit
e76feb6b8e
|
@ -18,6 +18,7 @@
|
|||
package org.apache.activemq.transport;
|
||||
|
||||
import java.io.IOException;
|
||||
import org.apache.activemq.command.ShutdownInfo;
|
||||
|
||||
|
||||
|
||||
|
@ -38,9 +39,13 @@ public class MutexTransport extends TransportFilter {
|
|||
}
|
||||
}
|
||||
|
||||
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);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue