Author: rajith
Date: Wed Jul 25 14:00:19 2007
New Revision: 559603
URL: http://svn.apache.org/viewvc?view=rev&rev=559603
Log:
code for session delegate
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java?view=diff&rev=559603&r1=559602&r2=559603
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
Wed Jul 25 14:00:19 2007
@@ -161,7 +161,7 @@
* @param nowait nowait
* @throws QpidException If the session fails to bind the queue due to
some error.
*/
- public void bindQueue(String queueName, String exchangeName, String
routingKey, boolean nowait)
+ public void bindQueue(String queueName, String exchangeName, String
routingKey)
throws
QpidException;
//Todo: Do we need to define more specific exceptions like exchange does
not exist?
@@ -187,7 +187,7 @@
* @param nowait nowait
* @throws QpidException If the session fails to purge the queue due to
some error.
*/
- public void purgeQueue(String queueName, boolean nowait)
+ public void purgeQueue(String queueName)
throws
QpidException;
@@ -224,7 +224,7 @@
* @throws QpidException If the session fails to declare the exchange due
to some error.
* @see DeclareExchangeOption
*/
- public void declareExchange(String exchangeName, String exchangeClass,
DeclareExchangeOption... options)
+ public void declareExchange(String exchangeName, String exchangeClass,
String alternateExchange, DeclareExchangeOption... options)
throws
QpidException;
//Todo: Do we need to define more specific exceptions like exchange
already exist?