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 | 4eb6a9f8a465fa31ff825971efa558f13787cb53 (patch) | |
tree | 8363d0e8fc381fc5fd7b84a8d1fd62b7fe99a4d4 /java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | |
parent | a28f991b3eec4b2f76449f494bd38269bae31bd3 (diff) | |
download | qpid-python-4eb6a9f8a465fa31ff825971efa558f13787cb53.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/qpid@1294370 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/AMQConnection.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index 39ad282422..b5a4300bd7 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/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 |