Skip to content

Commit

Permalink
added missing method to api
Browse files Browse the repository at this point in the history
  • Loading branch information
purplefox committed Dec 11, 2009
1 parent 1fae410 commit 789041a
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 0 deletions.
9 changes: 9 additions & 0 deletions src/main/org/hornetq/core/client/ClientSession.java
Expand Up @@ -187,6 +187,15 @@ public interface QueueQuery
* @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.
Expand Down
5 changes: 5 additions & 0 deletions src/main/org/hornetq/core/client/impl/DelegatingSession.java
Expand Up @@ -257,6 +257,11 @@ public void createQueue(final String address, final String queueName) throws Hor
{
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
{
Expand Down

0 comments on commit 789041a

Please sign in to comment.