1 files changed, 1 insertions, 2 deletions
diff --git a/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketConnector.java b/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketConnector.java
index 202ac1a530..cb24102edd 100644
--- a/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketConnector.java
+++ b/java/common/src/main/java/org/apache/mina/transport/socket/nio/MultiThreadSocketConnector.java
@@ -376,8 +376,7 @@ public class MultiThreadSocketConnector extends SocketConnector
 
         // Set the ConnectFuture of the specified session, which will be
         // removed and notified by AbstractIoFilterChain eventually.
-//        session.setAttribute( AbstractIoFilterChain.CONNECT_FUTURE, connectFuture );
-        session.setAttribute(AbstractIoFilterChain.class.getName() + ".connectFuture", connectFuture);
+        session.setAttribute( AbstractIoFilterChain.CONNECT_FUTURE, connectFuture );
 
         // Forward the remaining process to the SocketIoProcessor.
         session.getIoProcessor().addNew(session);