diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2010-06-14 12:37:11 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2010-06-14 12:37:11 +0000 |
| commit | 571a5c9a47f9681d00c6ae0487cbca29352f034b (patch) | |
| tree | 3d7912faedfe2661ecc78195fe05f1c96be0b588 /qpid/java/broker/src/test/java | |
| parent | ed9058f6a2584b9e4aa29caed99410ce71dbe814 (diff) | |
| download | qpid-python-571a5c9a47f9681d00c6ae0487cbca29352f034b.tar.gz | |
Update SAMQQT to use an initialised Direct exchange rather than make its own.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@954434 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test/java')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index cf46a1e97a..d9378a223b 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java @@ -26,6 +26,7 @@ import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.AMQException; import org.apache.qpid.AMQSecurityException; +import org.apache.qpid.exchange.ExchangeDefaults; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.BasicContentHeaderProperties; import org.apache.qpid.framing.ContentHeaderBody; @@ -59,7 +60,7 @@ public class SimpleAMQQueueTest extends InternalBrokerBaseCase protected AMQShortString _qname = new AMQShortString("qname"); protected AMQShortString _owner = new AMQShortString("owner"); protected AMQShortString _routingKey = new AMQShortString("routing key"); - protected DirectExchange _exchange = new DirectExchange(); + protected DirectExchange _exchange; protected MockSubscription _subscription = new MockSubscription(); protected FieldTable _arguments = null; @@ -104,6 +105,8 @@ public class SimpleAMQQueueTest extends InternalBrokerBaseCase applicationRegistry.getVirtualHostRegistry().registerVirtualHost(_virtualHost); _queue = (SimpleAMQQueue) AMQQueueFactory.createAMQQueueImpl(_qname, false, _owner, false, false, _virtualHost, _arguments); + + _exchange = (DirectExchange)_virtualHost.getExchangeRegistry().getExchange(ExchangeDefaults.DIRECT_EXCHANGE_NAME); } @Override |