From e4fb3cb982f7b22a9ee05ecc3c28832bade2b844 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 26 Nov 2012 17:03:36 +0000 Subject: QPID-4472 : [Java Test] Fix MultiVersionProtocolEngineTest to work with AMQP 1.0 connections. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1413724 13f79535-47bb-0310-9956-ffa450edef68 --- .../MultiVersionProtocolEngineFactoryTest.java | 26 ++++++++++++++++++++++ 1 file changed, 26 insertions(+) (limited to 'java') diff --git a/java/broker/src/test/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngineFactoryTest.java b/java/broker/src/test/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngineFactoryTest.java index 6081be8efd..e951dd494b 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngineFactoryTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/protocol/MultiVersionProtocolEngineFactoryTest.java @@ -20,12 +20,31 @@ */ package org.apache.qpid.server.protocol; +import java.util.UUID; +import java.util.concurrent.ScheduledFuture; import org.apache.commons.configuration.XMLConfiguration; import org.apache.qpid.protocol.ServerProtocolEngine; +import org.apache.qpid.server.binding.BindingFactory; import org.apache.qpid.server.configuration.ServerConfiguration; +import org.apache.qpid.server.configuration.VirtualHostConfiguration; +import org.apache.qpid.server.connection.IConnectionRegistry; +import org.apache.qpid.server.exchange.ExchangeFactory; +import org.apache.qpid.server.exchange.ExchangeRegistry; +import org.apache.qpid.server.protocol.v1_0.LinkRegistry; +import org.apache.qpid.server.queue.QueueRegistry; import org.apache.qpid.server.registry.ApplicationRegistry; +import org.apache.qpid.server.registry.IApplicationRegistry; +import org.apache.qpid.server.security.*; +import org.apache.qpid.server.stats.StatisticsCounter; +import org.apache.qpid.server.store.MessageStore; +import org.apache.qpid.server.txn.DtxRegistry; import org.apache.qpid.server.util.TestApplicationRegistry; +import org.apache.qpid.server.virtualhost.HouseKeepingTask; +import org.apache.qpid.server.virtualhost.State; +import org.apache.qpid.server.virtualhost.VirtualHost; +import org.apache.qpid.server.virtualhost.VirtualHostImpl; +import org.apache.qpid.server.virtualhost.VirtualHostRegistry; import org.apache.qpid.test.utils.QpidTestCase; import org.apache.qpid.transport.TestNetworkConnection; @@ -42,6 +61,12 @@ public class MultiVersionProtocolEngineFactoryTest extends QpidTestCase //the factory needs a registry instance ApplicationRegistry.initialise(new TestApplicationRegistry(new ServerConfiguration(new XMLConfiguration()))); + // AMQP 1-0 connection needs default vhost to be present + VirtualHostRegistry virtualHostRegistry = ApplicationRegistry.getInstance().getVirtualHostRegistry(); + VirtualHostImpl vhostImpl = new VirtualHostImpl(ApplicationRegistry.getInstance(), new VirtualHostConfiguration("default",new XMLConfiguration())); + virtualHostRegistry.registerVirtualHost(vhostImpl); + virtualHostRegistry.setDefaultVirtualHostName("default"); + } protected void tearDown() @@ -160,6 +185,7 @@ public class MultiVersionProtocolEngineFactoryTest extends QpidTestCase assertEquals("ID was not as expected following receipt of the AMQP version header", expectedID, engine.getConnectionId()); previousId = expectedID; + engine.closed(); } } -- cgit v1.2.1