From 4eddea8954ba9342ab2bc35e495baa673a6015db Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 25 Apr 2014 00:01:33 +0000 Subject: QPID-5578 : Ensure correct error code is returned when a queue is declared with an unknown alternate exchange git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1589912 13f79535-47bb-0310-9956-ffa450edef68 --- .../destination/AddressBasedDestinationTest.java | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) (limited to 'qpid/java/systests/src') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java index 3436b06db0..88f8142f94 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java @@ -20,7 +20,6 @@ */ package org.apache.qpid.test.client.destination; -import java.util.Collections; import java.util.Enumeration; import java.util.HashMap; import java.util.Hashtable; @@ -48,6 +47,7 @@ import javax.naming.InitialContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; + import org.apache.qpid.client.AMQAnyDestination; import org.apache.qpid.client.AMQConnection; import org.apache.qpid.client.AMQDestination; @@ -1226,6 +1226,23 @@ public class AddressBasedDestinationTest extends QpidBrokerTestCase cons.close(); } + public void testUnknownAltExchange() throws Exception + { + Session session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + String altQueueAddr = "ADDR:my-alt-queue;{create: always, delete: receiver,node:{x-bindings:[{exchange:'doesnotexist'}] }}"; + try + { + session.createConsumer(session.createQueue(altQueueAddr)); + fail("Attempt to create a queue with an unknown alternate exchange should fail"); + } + catch(JMSException e) + { + assertEquals("Failure code is not as expected", "404", e.getErrorCode()); + } + + + } + public void testQueueBrowserWithSelectorAutoAcknowledgement() throws Exception { assertQueueBrowserWithSelector(Session.AUTO_ACKNOWLEDGE); -- cgit v1.2.1