diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2014-10-10 09:54:36 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2014-10-10 09:54:36 +0000 |
commit | 89b0cfc3fd36bd8679c3f9343289c3dd98f5394f (patch) | |
tree | cc287c92cfe5d32ef19d8aaad1238862d385ab25 /java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java | |
parent | 146fcaecb92b7579fa6927dceecfe32ab92378c4 (diff) | |
download | qpid-python-89b0cfc3fd36bd8679c3f9343289c3dd98f5394f.tar.gz |
More refactoring
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1630745 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java')
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java b/java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java index 4020d8fb23..b8af656a35 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/BasicGetOkBody.java @@ -151,15 +151,15 @@ public class BasicGetOkBody extends AMQMethodBodyImpl implements EncodableAMQDat 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 { long deliveryTag = buffer.readLong(); boolean redelivered = (buffer.readByte() & 0x01) != 0; AMQShortString exchange = buffer.readAMQShortString(); AMQShortString routingKey = buffer.readAMQShortString(); long messageCount = EncodingUtils.readUnsignedInteger(buffer); - return dispatcher.basicGetOk(channelId, deliveryTag, redelivered, exchange, routingKey, messageCount); + dispatcher.receiveBasicGetOk(channelId, deliveryTag, redelivered, exchange, routingKey, messageCount); } } |