diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-02-27 22:27:40 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-02-27 22:27:40 +0000 |
| commit | f80d421edf6a3775b563cba41aaaa4d1d258bdf3 (patch) | |
| tree | 365d9590008c26a944d03af693bafb230300f96d | |
| parent | 510c01f6251d62bb9ab2d312410e448ca986800b (diff) | |
| download | qpid-python-f80d421edf6a3775b563cba41aaaa4d1d258bdf3.tar.gz | |
QPID-2020 : [Java Client] create[Durable]ConnectionConsumer should throw JMSException, not return null (until such time as QPID-3693 is completed)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294370 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index 39ad282422..b5a4300bd7 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -968,7 +968,8 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect { checkNotClosed(); - return null; + throw new JmsNotImplementedException(); + } public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, @@ -976,7 +977,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect { checkNotClosed(); - return null; + throw new JmsNotImplementedException(); } public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, @@ -984,7 +985,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect { checkNotClosed(); - return null; + throw new JmsNotImplementedException(); } public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, @@ -993,7 +994,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect // TODO Auto-generated method stub checkNotClosed(); - return null; + throw new JmsNotImplementedException(); } public long getMaximumChannelCount() throws JMSException |