summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2007-01-15 16:26:00 +0000
committerKim van der Riet <kpvdr@apache.org>2007-01-15 16:26:00 +0000
commitfa15e6d52022cc1576b19e3caaecf66260c1923e (patch)
treea00bdc846c8b772faf199d228a60db87d75c7939 /java/broker
parent9ba2ca90c9127ea98372a9758e731dd9fe19c212 (diff)
downloadqpid-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.java20
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));
-// }
-// }
}
}