diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java index bd6a02d69b..b074da8ac1 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersExchangeTest.java @@ -21,8 +21,8 @@ package org.apache.qpid.server.exchange; import org.apache.qpid.AMQException; -import org.apache.qpid.server.protocol.AMQProtocolSession; -import org.apache.qpid.server.protocol.InternalTestProtocolSession; +import org.apache.qpid.server.protocol.v0_8.AMQProtocolSession; +import org.apache.qpid.server.protocol.v0_8.InternalTestProtocolSession; import org.apache.qpid.server.util.BrokerTestHelper; public class HeadersExchangeTest extends AbstractHeadersExchangeTestBase @@ -104,22 +104,22 @@ public class HeadersExchangeTest extends AbstractHeadersExchangeTestBase pb2.setMandatory(true); routeAndTest(m1,true); } - + public void testOnUnbind() throws AMQException { TestQueue q1 = bindDefault("F0000"); TestQueue q2 = bindDefault("F0000=Aardvark"); TestQueue q3 = bindDefault("F0001"); - + routeAndTest(new Message(_protocolSession, "Message1", "F0000"), q1); routeAndTest(new Message(_protocolSession, "Message2", "F0000=Aardvark"), q1, q2); routeAndTest(new Message(_protocolSession, "Message3", "F0001"), q3); - + unbind(q1,"F0000"); routeAndTest(new Message(_protocolSession, "Message4", "F0000")); routeAndTest(new Message(_protocolSession, "Message5", "F0000=Aardvark"), q2); } - + public static junit.framework.Test suite() { |