svn commit: r687749 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java

[ritchiem]

Author: ritchiem
Date: Thu Aug 21 06:22:22 2008
New Revision: 687749

URL: http://svn.apache.org/viewvc?rev=687749&view=rev
Log:
Sorry went crazy with git and didn't meant to commit this change

Modified:
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java?rev=687749&r1=687748&r2=687749&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
 Thu Aug 21 06:22:22 2008
@@ -230,8 +230,7 @@
                     _logger.info("Channel[" + channelId + "] awaiting closure. 
Should close socket as client did not close-ok :" + frame);
                 }
 
-
-//                closeProtocolSession();
+                closeProtocolSession();
                 return;
             }
         }
@@ -273,7 +272,7 @@
         }
         catch (AMQException e)
         {
-            _logger.info("Received incorrect protocol initiation:" + 
e.getMessage());
+            _logger.error("Received incorrect protocol initiation", e);
 
             _minaProtocolSession.write(new 
ProtocolInitiation(ProtocolVersion.getLatestSupportedVersion()));
 
@@ -357,7 +356,7 @@
 
             _logger.error("Unexpected exception while processing frame.  
Closing connection.", e);
 
-//            closeProtocolSession();
+            closeProtocolSession();
         }
     }