diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java index 6da18592fb..65cee13dad 100644 --- a/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java @@ -149,7 +149,7 @@ public class NIOTransport extends TcpTransport { } protected void doStop(ServiceStopper stopper) throws Exception { - selection.disable(); + selection.close(); super.doStop(stopper); } }