diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-18 16:31:26 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-18 16:31:26 +0000 |
| commit | 05306462d72913a31775420b024252dc0f71e30a (patch) | |
| tree | ecc8e0c729102fe0356b31191073a85632c303b9 /java | |
| parent | 0cf4115fb4d6f5fd10bff72451e747b5bdd72307 (diff) | |
| download | qpid-python-05306462d72913a31775420b024252dc0f71e30a.tar.gz | |
Completed broker MessageQosHandler
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497489 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java index 6bea5553d9..47d6163bf3 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java +++ b/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java @@ -22,6 +22,7 @@ package org.apache.qpid.server.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageQosBody; +import org.apache.qpid.framing.MessageOkBody; import org.apache.qpid.protocol.AMQMethodEvent; import org.apache.qpid.server.exchange.ExchangeRegistry; import org.apache.qpid.server.protocol.AMQProtocolSession; @@ -48,7 +49,11 @@ public class MessageQosHandler implements StateAwareMethodListener<MessageQosBod AMQMethodEvent<MessageQosBody> evt) throws AMQException { - // TODO + protocolSession.getChannel(evt.getChannelId()).setPrefetchCount(evt.getMethod().prefetchCount); + // AMQP version change: Hardwire the version to 0-9 (major=0, minor=9) + // TODO: Connect this to the session version obtained from ProtocolInitiation for this session. + // Be aware of possible changes to parameter order as versions change. + protocolSession.writeResponse(evt.getChannelId(), evt.getRequestId(), new MessageOkBody((byte)0, (byte)9)); } } |