Author: arnaudsimon
Date: Wed Jun 27 07:11:31 2007
New Revision: 551168
URL: http://svn.apache.org/viewvc?view=rev&rev=551168
Log:
added public void declareAndBind(AMQDestination amqd)
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?view=diff&rev=551168&r1=551167&r2=551168
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Wed Jun 27 07:11:31 2007
@@ -1279,6 +1279,16 @@
}
}
+ public void declareAndBind(AMQDestination amqd)
+ throws
+ AMQException
+ {
+ AMQProtocolHandler protocolHandler = getProtocolHandler();
+ declareExchange(amqd, protocolHandler, false);
+ AMQShortString queueName = declareQueue(amqd, protocolHandler);
+ bindQueue(queueName, amqd.getRoutingKey(), new FieldTable(),
amqd.getExchangeName());
+ }
+
/**
* Stops message delivery in this session, and restarts message delivery
with the oldest unacknowledged message.
*
