From fa15e6d52022cc1576b19e3caaecf66260c1923e Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Mon, 15 Jan 2007 16:26:00 +0000 Subject: Request and Respone managers now use the new common AMQMethodListener class git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496389 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/server/protocol/AMQMinaProtocolSession.java | 20 -------------------- 1 file changed, 20 deletions(-) (limited to 'java/broker/src/main') 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 1505b2cfc5..e163086c14 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 @@ -36,9 +36,7 @@ import org.apache.qpid.framing.ProtocolVersionList; import org.apache.qpid.framing.AMQMethodBody; import org.apache.qpid.framing.AMQRequestBody; import org.apache.qpid.framing.AMQResponseBody; -//import org.apache.qpid.framing.ContentBody; import org.apache.qpid.framing.HeartbeatBody; -//import org.apache.qpid.framing.ContentHeaderBody; import org.apache.qpid.codec.AMQCodecFactory; import org.apache.qpid.codec.AMQDecoder; import org.apache.qpid.protocol.AMQMethodEvent; @@ -221,24 +219,6 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, { _logger.error("Received invalid frame: " + frame.toString()); } -// else if (frame.bodyFrame instanceof AMQMethodBody) -// { -// methodFrameReceived(frame); -// } -// else -// { -// try -// { -// contentFrameReceived(frame); -// } -// catch (RequiredDeliveryException e) -// { -// //need to return the message: -// _logger.info("Returning message to " + this + " channel " + frame.channel -// + ": " + e.getMessage()); -// writeFrame(e.getReturnMessage(frame.channel)); -// } -// } } } -- cgit v1.2.1