You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2010/04/15 21:32:23 UTC
svn commit: r934559 - in
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client:
AMQQueue.java AMQSession.java AMQTopic.java
Author: rajith
Date: Thu Apr 15 19:32:22 2010
New Revision: 934559
URL: http://svn.apache.org/viewvc?rev=934559&view=rev
Log:
QPID-2496
This allows a user to pass in an address string when creating a queue or topic using the JMS 1.0 methods (session.createQueue(String s) and session.createTopic(String s) )
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java?rev=934559&r1=934558&r2=934559&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java Thu Apr 15 19:32:22 2010
@@ -20,6 +20,8 @@
*/
package org.apache.qpid.client;
+import java.net.URISyntaxException;
+
import javax.jms.Queue;
import org.apache.qpid.exchange.ExchangeDefaults;
@@ -29,6 +31,11 @@ import org.apache.qpid.url.BindingURL;
public class AMQQueue extends AMQDestination implements Queue
{
+ public AMQQueue(String address) throws URISyntaxException
+ {
+ super(address);
+ }
+
/**
* Create a reference to a non temporary queue using a BindingURL object.
* Note this does not actually imply the queue exists.
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=934559&r1=934558&r2=934559&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java Thu Apr 15 19:32:22 2010
@@ -1071,6 +1071,7 @@ public abstract class AMQSession<C exten
public Queue createQueue(String queueName) throws JMSException
{
checkNotClosed();
+
if (queueName.indexOf('/') == -1)
{
return new AMQQueue(getDefaultQueueExchangeName(), new AMQShortString(queueName));
@@ -1079,7 +1080,7 @@ public abstract class AMQSession<C exten
{
try
{
- return new AMQQueue(new AMQBindingURL(queueName));
+ return new AMQQueue(queueName);
}
catch (URISyntaxException urlse)
{
@@ -1090,6 +1091,7 @@ public abstract class AMQSession<C exten
throw jmse;
}
}
+
}
/**
@@ -1344,7 +1346,7 @@ public abstract class AMQSession<C exten
{
try
{
- return new AMQTopic(new AMQBindingURL(topicName));
+ return new AMQTopic(topicName);
}
catch (URISyntaxException urlse)
{
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java?rev=934559&r1=934558&r2=934559&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java Thu Apr 15 19:32:22 2010
@@ -20,6 +20,8 @@
*/
package org.apache.qpid.client;
+import java.net.URISyntaxException;
+
import javax.jms.JMSException;
import javax.jms.Topic;
@@ -29,6 +31,11 @@ import org.apache.qpid.url.BindingURL;
public class AMQTopic extends AMQDestination implements Topic
{
+ public AMQTopic(String address) throws URISyntaxException
+ {
+ super(address);
+ }
+
/**
* Constructor for use in creating a topic using a BindingURL.
*
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org