diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
index 02c0063f24..a15bf463e1 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
@@ -464,8 +464,6 @@ public class TcpTransport extends TransportThreadSupport implements Transport, S
     
                     public void run() {
                         try {
-                            socket.shutdownInput();
-                            socket.shutdownOutput();
                             socket.close();
                         } catch (IOException e) {
                             LOG.debug("Caught exception closing socket",e);