summaryrefslogtreecommitdiff
path: root/qpid/java/systests/src
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/systests/src')
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java19
1 files changed, 18 insertions, 1 deletions
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);