summaryrefslogtreecommitdiff
path: root/java/broker/src/main
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-08-21 13:22:22 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-08-21 13:22:22 +0000
commiteaa4edf9e8a4639aea35fe741830036e10122393 (patch)
treea6da3090b698dceb00e03e19135e478cee183a65 /java/broker/src/main
parent0d871420b20d4e98fde5b959883ec2a8f4eb4d5c (diff)
downloadqpid-python-eaa4edf9e8a4639aea35fe741830036e10122393.tar.gz
Sorry went crazy with git and didn't meant to commit this change
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687749 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/main')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java7
1 files changed, 3 insertions, 4 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
index aec032bb54..239d9d8822 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
@@ -230,8 +230,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
_logger.info("Channel[" + channelId + "] awaiting closure. Should close socket as client did not close-ok :" + frame);
}
-
-// closeProtocolSession();
+ closeProtocolSession();
return;
}
}
@@ -273,7 +272,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
}
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 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
_logger.error("Unexpected exception while processing frame. Closing connection.", e);
-// closeProtocolSession();
+ closeProtocolSession();
}
}