diff options
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java')
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java b/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java index fc9795f48b..408f9f9667 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java @@ -151,9 +151,9 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa return buf.toString(); } - public static <T> T process(final int channelId, + public static void process(final int channelId, final MarkableDataInput buffer, - final MethodProcessor<T> dispatcher) throws IOException + final MethodProcessor dispatcher) throws IOException { int ticket = buffer.readUnsignedShort(); @@ -163,6 +163,6 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa boolean ifUnused = (bitfield & 0x01) == 0x01; boolean ifEmpty = (bitfield & 0x02) == 0x02; boolean nowait = (bitfield & 0x04) == 0x04; - return dispatcher.queueDelete(channelId, queue, ifUnused, ifEmpty, nowait); + dispatcher.receiveQueueDelete(channelId, queue, ifUnused, ifEmpty, nowait); } } |