From d1e7aed5b442767e4a81a64f21266b181047690d Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Mon, 24 Sep 2007 14:26:14 +0000 Subject: added field table encoding/decoding git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578827 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpidity/nclient/Session.java | 10 +++++----- .../java/org/apache/qpidity/nclient/impl/ClientSession.java | 2 +- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'java/client') diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/Session.java b/java/client/src/main/java/org/apache/qpidity/nclient/Session.java index f2e28eb8e7..b99e1f2f2a 100644 --- a/java/client/src/main/java/org/apache/qpidity/nclient/Session.java +++ b/java/client/src/main/java/org/apache/qpidity/nclient/Session.java @@ -260,7 +260,7 @@ public interface Session * on the providers implementation. */ public void messageSubscribe(String queue, String destination, short confirmMode, short acquireMode, - MessagePartListener listener, Map filter, Option... options); + MessagePartListener listener, Map filter, Option... options); /** * This method cancels a consumer. This does not affect already delivered messages, but it does @@ -481,7 +481,7 @@ public interface Session * {@link Option#EXCLUSIVE}, {@link Option#PASSIVE} and {@link Option#NO_OPTION}) * @see Option */ - public void queueDeclare(String queueName, String alternateExchange, Map arguments, Option... options); + public void queueDeclare(String queueName, String alternateExchange, Map arguments, Option... options); /** * Bind a queue with an exchange. @@ -498,7 +498,7 @@ public interface Session * routing keys depends on the exchange implementation. * @param arguments Used for backward compatibility */ - public void queueBind(String queueName, String exchangeName, String routingKey, Map arguments); + public void queueBind(String queueName, String exchangeName, String routingKey, Map arguments); /** * Unbind a queue from an exchange. @@ -508,7 +508,7 @@ public interface Session * @param routingKey Specifies the routing key of the binding to unbind. * @param arguments Used for backward compatibility */ - public void queueUnbind(String queueName, String exchangeName, String routingKey, Map arguments); + public void queueUnbind(String queueName, String exchangeName, String routingKey, Map arguments); /** * This method removes all messages from a queue. It does not cancel consumers. Purged messages @@ -573,7 +573,7 @@ public interface Session * @param arguments Used for backward compatibility * @see Option */ - public void exchangeDeclare(String exchangeName, String type, String alternateExchange, Map arguments, + public void exchangeDeclare(String exchangeName, String type, String alternateExchange, Map arguments, Option... options); /** diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java index f6aa444881..69b04490ff 100644 --- a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java +++ b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java @@ -35,7 +35,7 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen } } - public void messageSubscribe(String queue, String destination, short confirmMode, short acquireMode, MessagePartListener listener, Map filter, Option... options) + public void messageSubscribe(String queue, String destination, short confirmMode, short acquireMode, MessagePartListener listener, Map filter, Option... options) { setMessageListener(destination,listener); super.messageSubscribe(queue, destination, confirmMode, acquireMode, filter, options); -- cgit v1.2.1