You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/08/21 15:22:23 UTC
svn commit: r687749 -
/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
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();
}
}