QPID-4409 : [AMQP 1.0 JMS] QueueConnection createDurableConnectionConsumer() should throw IllegalStateException

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1404967 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 0 deletions

diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
index 28aacc3f44..417f6f71e1 100644
--- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
+++ b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
@@ -331,6 +331,10 @@ public class ConnectionImpl implements Connection, QueueConnection, TopicConnect
                                                               final int i) throws JMSException

     {

         checkClosed();

+        if (_isQueueConnection)

+        {

+            throw new IllegalStateException("QueueConnection cannot be used to create Pub/Sub based resources.");

+        } 

         return null;  //TODO

     }