diff options
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java')
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java b/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java index 9857bb3a39..cf6fc656b3 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java @@ -120,13 +120,15 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM return buf.toString(); } - public static void process(final int channelId, - final MarkableDataInput buffer, - final MethodProcessor dispatcher) throws IOException + public static void process(final MarkableDataInput buffer, + final ClientChannelMethodProcessor dispatcher) throws IOException { AMQShortString queue = buffer.readAMQShortString(); long messageCount = EncodingUtils.readUnsignedInteger(buffer); long consumerCount = EncodingUtils.readUnsignedInteger(buffer); - dispatcher.receiveQueueDeclareOk(channelId, queue, messageCount, consumerCount); + if(!dispatcher.ignoreAllButCloseOk()) + { + dispatcher.receiveQueueDeclareOk(queue, messageCount, consumerCount); + } } } |