summaryrefslogtreecommitdiff
path: root/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-10-10 09:54:36 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-10-10 09:54:36 +0000
commit89b0cfc3fd36bd8679c3f9343289c3dd98f5394f (patch)
treecc287c92cfe5d32ef19d8aaad1238862d385ab25 /java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java
parent146fcaecb92b7579fa6927dceecfe32ab92378c4 (diff)
downloadqpid-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/QueueDeclareOkBody.java')
-rw-r--r--java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java6
1 files changed, 3 insertions, 3 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 47deb9cd6d..9857bb3a39 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,13 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM
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
{
AMQShortString queue = buffer.readAMQShortString();
long messageCount = EncodingUtils.readUnsignedInteger(buffer);
long consumerCount = EncodingUtils.readUnsignedInteger(buffer);
- return dispatcher.queueDeclareOk(channelId, queue, messageCount, consumerCount);
+ dispatcher.receiveQueueDeclareOk(channelId, queue, messageCount, consumerCount);
}
}