Author: timfox
Date: 2009-12-11 06:17:40 -0500 (Fri, 11 Dec 2009)
New Revision: 8673
Modified:
trunk/src/main/org/hornetq/core/client/ClientSession.java
trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java
Log:
added missing method to api
Modified: trunk/src/main/org/hornetq/core/client/ClientSession.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/ClientSession.java 2009-12-11 11:02:23 UTC (rev
8672)
+++ trunk/src/main/org/hornetq/core/client/ClientSession.java 2009-12-11 11:17:40 UTC (rev
8673)
@@ -187,6 +187,15 @@
* @throws HornetQException in an exception occurs while creating the queue
*/
void createQueue(String address, String queueName) throws HornetQException;
+
+ /**
+ * Creates a <em>non-temporary</em> queue <em>non-durable</em>
queue.
+ *
+ * @param address the queue will be bound to this address
+ * @param queueName the name of the queue
+ * @throws HornetQException in an exception occurs while creating the queue
+ */
+ void createQueue(SimpleString address, SimpleString queueName) throws
HornetQException;
/**
* Creates a <em>non-temporary</em> queue.
Modified: trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java 2009-12-11 11:02:23
UTC (rev 8672)
+++ trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java 2009-12-11 11:17:40
UTC (rev 8673)
@@ -257,6 +257,11 @@
{
session.createQueue(address, queueName);
}
+
+ public void createQueue(final SimpleString address, final SimpleString queueName)
throws HornetQException
+ {
+ session.createQueue(address, queueName);
+ }
public void createQueue(final SimpleString address, final SimpleString queueName,
final boolean durable) throws HornetQException
{
Show replies by date