diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-15 16:26:00 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-15 16:26:00 +0000 |
| commit | fa15e6d52022cc1576b19e3caaecf66260c1923e (patch) | |
| tree | a00bdc846c8b772faf199d228a60db87d75c7939 /java/broker | |
| parent | 9ba2ca90c9127ea98372a9758e731dd9fe19c212 (diff) | |
| download | qpid-python-fa15e6d52022cc1576b19e3caaecf66260c1923e.tar.gz | |
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
Diffstat (limited to 'java/broker')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java | 20 |
1 files changed, 0 insertions, 20 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 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)); -// } -// } } } |
