[hornetq-commits] JBoss hornetq SVN: r8673 - in trunk/src/main/org/hornetq/core/client: impl and 1 other directory.

[do-not-reply at jboss.org]

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
    {