From e9837560e159f680d30bc1135d6ee8ed9b124ab4 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 2 Nov 2012 14:04:51 +0000 Subject: QPID-4409 : [AMQP 1.0 JMS] QueueConnection createDurableConnectionConsumer() should throw IllegalStateException git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1404967 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'java') diff --git a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java index 28aacc3f44..417f6f71e1 100644 --- a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java +++ b/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 } -- cgit v1.2.1