diff options
| author | Alex Rudyy <orudyy@apache.org> | 2014-06-26 08:25:56 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2014-06-26 08:25:56 +0000 |
| commit | 73e49b5fc7ebcb9235265f648dbb7f3cc522752a (patch) | |
| tree | 99f4ee00bde4037d7289ef2a6efb39f9090052ba | |
| parent | 0b2d26c6f3107946a2e83d764aad9c08eea57d0c (diff) | |
| download | qpid-python-73e49b5fc7ebcb9235265f648dbb7f3cc522752a.tar.gz | |
QPID-5851: [Java Broker] Introduce new test profiles for JSON configuration store and persistent message store
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1605697 13f79535-47bb-0310-9956-ffa450edef68
9 files changed, 137 insertions, 41 deletions
diff --git a/qpid/java/pom.xml b/qpid/java/pom.xml index 4cbff8b55b..71984fe9ed 100644 --- a/qpid/java/pom.xml +++ b/qpid/java/pom.xml @@ -47,7 +47,7 @@ <properties> <!-- enforcer plugin config properties --> - <supported-test-profiles-regex>(java-mms.0-9|java-mms.0-9-1|java-mms.0-10|java-bdb.0-9|java-bdb.0-9-1|java-bdb.0-10|java-dby.0-9|java-dby.0-9-1|java-dby.0-10|java-dby-mem.0-9|java-dby-mem.0-9-1|java-dby-mem.0-10|cpp)</supported-test-profiles-regex> + <supported-test-profiles-regex>(java-mms.0-9|java-mms.0-9-1|java-mms.0-10|java-bdb.0-9|java-bdb.0-9-1|java-bdb.0-10|java-dby.0-9|java-dby.0-9-1|java-dby.0-10|java-dby-mem.0-9|java-dby-mem.0-9-1|java-dby-mem.0-10|cpp|java-json.0-9-1|java-json.0-10)</supported-test-profiles-regex> <!-- test profile properties and defaults--> <qpid.home>${basedir}</qpid.home> <!-- override for broker tests --> @@ -60,15 +60,17 @@ <profile.broker.type>internal</profile.broker.type> <profile.broker.stopped>Exception</profile.broker.stopped> <profile.broker.ready>BRK-1004</profile.broker.ready> - <profile.broker.command>${qpid.home}${file.separator}bin${file.separator}qpid-server -sp @STORE_PATH -st @STORE_TYPE -l @LOG_CONFIG_FILE</profile.broker.command> - <profile.broker.command.windows>${qpid.home}${file.separator}bin${file.separator}qpid-server.bat -sp @STORE_PATH -st @STORE_TYPE -l @LOG_CONFIG_FILE</profile.broker.command.windows> + <profile.broker.command>${qpid.home}${file.separator}bin${file.separator}qpid-server -sp ${at.sign}STORE_PATH -st ${at.sign}STORE_TYPE -l ${at.sign}LOG_CONFIG_FILE</profile.broker.command> + <profile.broker.command.windows>${qpid.home}${file.separator}bin${file.separator}qpid-server.bat -sp ${at.sign}STORE_PATH -st ${at.sign}STORE_TYPE -l ${at.sign}LOG_CONFIG_FILE</profile.broker.command.windows> <profile.test.excludes>Excludes JavaExcludes ${profile}.excludes ${profile.specific.excludes}</profile.test.excludes> <profile.specific.excludes>JavaTransientExcludes Java010Excludes</profile.specific.excludes> <profile.broker.version>v0_10</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>false</profile.broker.persistent> - <profile.messagestore.type>Memory</profile.messagestore.type> + <profile.virtualhostnode.type>Memory</profile.virtualhostnode.type> <profile.broker.clean.between.tests>true</profile.broker.clean.between.tests> + <dollar.sign>$</dollar.sign> + <at.sign>@</at.sign> </properties> <modules> @@ -172,7 +174,8 @@ <echo>[profile.broker.version] ${profile.broker.version}</echo> <echo>[profile.qpid.broker_default_amqp_protocol_excludes] ${profile.qpid.broker_default_amqp_protocol_excludes}</echo> <echo>[profile.broker.persistent] ${profile.broker.persistent}</echo> - <echo>[profile.messagestore.type] ${profile.messagestore.type}</echo> + <echo>[profile.virtualhostnode.type] ${profile.virtualhostnode.type}</echo> + <echo>[profile.virtualhostnode.context.blueprint] ${profile.virtualhostnode.context.blueprint}</echo> </target> </configuration> </execution> @@ -238,7 +241,8 @@ <broker.version>${profile.broker.version}</broker.version> <qpid.broker_default_amqp_protocol_excludes>${profile.qpid.broker_default_amqp_protocol_excludes}</qpid.broker_default_amqp_protocol_excludes> <broker.persistent>${profile.broker.persistent}</broker.persistent> - <messagestore.type>${profile.messagestore.type}</messagestore.type> + <virtualhostnode.type>${profile.virtualhostnode.type}</virtualhostnode.type> + <virtualhostnode.context.blueprint>${profile.virtualhostnode.context.blueprint}</virtualhostnode.context.blueprint> <broker.clean.between.tests>${profile.broker.clean.between.tests}</broker.clean.between.tests> <!-- This must be a child of qpid home currently due to the horrible mechanics of QBTC --> @@ -396,7 +400,8 @@ <profile.broker.version>v0_10</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>false</profile.broker.persistent> - <profile.messagestore.type>Memory</profile.messagestore.type> + <profile.virtualhostnode.type>Memory</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -414,7 +419,8 @@ <profile.broker.version>v0_9_1</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>false</profile.broker.persistent> - <profile.messagestore.type>Memory</profile.messagestore.type> + <profile.virtualhostnode.type>Memory</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -432,7 +438,8 @@ <profile.broker.version>v0_9</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10,AMQP_0_9_1</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>false</profile.broker.persistent> - <profile.messagestore.type>Memory</profile.messagestore.type> + <profile.virtualhostnode.type>Memory</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -450,7 +457,8 @@ <profile.broker.version>v0_10</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>BDB</profile.messagestore.type> + <profile.virtualhostnode.type>BDB</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -468,7 +476,8 @@ <profile.broker.version>v0_9_1</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>BDB</profile.messagestore.type> + <profile.virtualhostnode.type>BDB</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -486,7 +495,8 @@ <profile.broker.version>v0_9</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10,AMQP_0_9_1</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>BDB</profile.messagestore.type> + <profile.virtualhostnode.type>BDB</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -504,7 +514,8 @@ <profile.broker.version>v0_10</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -522,7 +533,8 @@ <profile.broker.version>v0_9_1</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -540,7 +552,8 @@ <profile.broker.version>v0_9</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10,AMQP_0_9_1</profile.qpid.broker_default_amqp_protocol_excludes> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -557,9 +570,9 @@ <profile.specific.excludes>JavaPersistentExcludes JavaDerbyExcludes Java010Excludes</profile.specific.excludes> <profile.broker.version>v0_10</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> - <profile.broker.virtualhosts-config>${QPID_HOME}${file.separator}etc${file.separator}virtualhosts-systests-derby.xml</profile.broker.virtualhosts-config> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -576,9 +589,9 @@ <profile.specific.excludes>JavaPersistentExcludes JavaDerbyExcludes XAExcludes JavaPre010Excludes</profile.specific.excludes> <profile.broker.version>v0_9_1</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10</profile.qpid.broker_default_amqp_protocol_excludes> - <profile.broker.virtualhosts-config>${QPID_HOME}${file.separator}etc${file.separator}virtualhosts-systests-derby.xml</profile.broker.virtualhosts-config> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> @@ -595,13 +608,56 @@ <profile.specific.excludes>JavaPersistentExcludes JavaDerbyExcludes XAExcludes JavaPre010Excludes</profile.specific.excludes> <profile.broker.version>v0_9</profile.broker.version> <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10,AMQP_0_9_1</profile.qpid.broker_default_amqp_protocol_excludes> - <profile.broker.virtualhosts-config>${QPID_HOME}${file.separator}etc${file.separator}virtualhosts-systests-derby.xml</profile.broker.virtualhosts-config> <profile.broker.persistent>true</profile.broker.persistent> - <profile.messagestore.type>DERBY</profile.messagestore.type> + <profile.virtualhostnode.type>DERBY</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"ProvidedStore"}</profile.virtualhostnode.context.blueprint> </properties> </profile> + <!-- + Split store profiles. + Virtual host configuration can be overridden by setting blueprint property like below + -Dprofile.virtualhostnode.context.blueprint='{"type":"BDB","messageStoreSettings":{"storePath":"${QPID_WORK}/${this:name}/bdb"}}' + --> <profile> + <id>java-json.0-9-1</id> + <activation> + <property> + <name>profile</name> + <value>java-json.0-9-1</value> + </property> + </activation> + <properties> + <profile>java-json.0-9-1</profile> + <profile.specific.excludes>JavaPersistentExcludes JavaJsonExcludes XAExcludes JavaPre010Excludes</profile.specific.excludes> + <profile.broker.version>v0_9_1</profile.broker.version> + <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0,AMQP_0_10</profile.qpid.broker_default_amqp_protocol_excludes> + <profile.broker.persistent>true</profile.broker.persistent> + <profile.virtualhostnode.type>JSON</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"DERBY","messageStoreSettings":{"storePath":"${dollar.sign}{QPID_WORK}/${dollar.sign}{this:name}/derby"}}</profile.virtualhostnode.context.blueprint> + </properties> + </profile> + + <profile> + <id>java-json.0-10</id> + <activation> + <property> + <name>profile</name> + <value>java-json.0-10</value> + </property> + </activation> + <properties> + <profile>java-json.0-10</profile> + <profile.specific.excludes>JavaPersistentExcludes JavaJsonExcludes XAExcludes Java010Excludes</profile.specific.excludes> + <profile.broker.version>v0_10</profile.broker.version> + <profile.qpid.broker_default_amqp_protocol_excludes>AMQP_1_0</profile.qpid.broker_default_amqp_protocol_excludes> + <profile.broker.persistent>true</profile.broker.persistent> + <profile.virtualhostnode.type>JSON</profile.virtualhostnode.type> + <profile.virtualhostnode.context.blueprint>{"type":"DERBY","messageStoreSettings":{"storePath":"${dollar.sign}{QPID_WORK}/${dollar.sign}{this:name}/derby"}}</profile.virtualhostnode.context.blueprint> + </properties> + </profile> + + <profile> <id>cpp</id> <activation> <property> @@ -615,7 +671,7 @@ <profile.broker.type>spawned</profile.broker.type> <profile.broker.stopped>Exception constructed</profile.broker.stopped> <profile.broker.ready>Listening on TCP</profile.broker.ready> - <profile.broker.command>${cpp-broker-dir}/qpidd -p @PORT --data-dir ${qpid.work}/@PORT -t --auth no --no-module-dir</profile.broker.command> + <profile.broker.command>${cpp-broker-dir}/qpidd -p ${at.sign}PORT --data-dir ${qpid.work}/${at.sign}PORT -t --auth no --no-module-dir</profile.broker.command> <profile.broker.command.windows /> <profile.test.excludes>Excludes CPPExcludes ${profile}.excludes ${profile.specific.excludes} cpp.excludes</profile.test.excludes> <profile.specific.excludes>CPPPrefetchExcludes CPPTransientExcludes</profile.specific.excludes> diff --git a/qpid/java/qpid-test-utils/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java b/qpid/java/qpid-test-utils/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java index ca80ad09c2..5a3c0182fd 100644 --- a/qpid/java/qpid-test-utils/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java +++ b/qpid/java/qpid-test-utils/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java @@ -35,12 +35,13 @@ import junit.framework.TestResult; import org.apache.log4j.Level; import org.apache.log4j.Logger; - public class QpidTestCase extends TestCase { private static final String TEST_EXCLUDES = "test.excludes"; private static final String TEST_EXCLUDELIST = "test.excludelist"; private static final String TEST_EXCLUDEFILES = "test.excludefiles"; + private static final String VIRTUAL_HOST_NODE_TYPE = "virtualhostnode.type"; + private static final String VIRTUAL_HOST_NODE_CONTEXT_BLUEPRINT = "virtualhostnode.context.blueprint"; public static final String QPID_HOME = System.getProperty("QPID_HOME"); public static final String TEST_RESOURCES_DIR = QPID_HOME + "/../test-profiles/test_resources/"; public static final String TEST_PROFILES_DIR = QPID_HOME + "/../test-profiles/"; @@ -124,8 +125,6 @@ public class QpidTestCase extends TestCase } } - protected static final String MESSAGE_STORE_TYPE = "messagestore.type"; - private static List<String> _exclusionList; public QpidTestCase() @@ -148,17 +147,21 @@ public class QpidTestCase extends TestCase } } - public String getTestProfileMessageStoreType() + public String getTestProfileVirtualHostNodeType() { - final String storeType = System.getProperty(MESSAGE_STORE_TYPE); - _logger.debug(MESSAGE_STORE_TYPE + "=" + storeType); + final String storeType = System.getProperty(VIRTUAL_HOST_NODE_TYPE); + + if (_logger.isDebugEnabled()) + { + _logger.debug(VIRTUAL_HOST_NODE_TYPE + "=" + storeType); + } return storeType != null ? storeType : "TestMemory"; } - public String getTestProfileVirtualHostNodeType() + public String getTestProfileVirtualHostNodeBlueprint() { - return getTestProfileMessageStoreType(); + return System.getProperty(VIRTUAL_HOST_NODE_CONTEXT_BLUEPRINT); } public static final int MIN_PORT_NUMBER = 1; diff --git a/qpid/java/systests/etc/config-systests.json b/qpid/java/systests/etc/config-systests.json index ac5c46ad6a..27124de1fb 100644 --- a/qpid/java/systests/etc/config-systests.json +++ b/qpid/java/systests/etc/config-systests.json @@ -59,10 +59,10 @@ }], "virtualhostnodes" : [ { "name" : "test", - "type" : "${messagestore.type}", + "type" : "${virtualhostnode.type}", "storePath" : "${QPID_WORK}/${test.port}/test/config", "context" : { - "virtualhostBlueprint" : "{ \"type\" : \"ProvidedStore\" }" + "virtualhostBlueprint" : "${virtualhostnode.context.blueprint}" } } ] } diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SplitStoreTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SplitStoreTest.java index 0f67121212..7605c8a024 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SplitStoreTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SplitStoreTest.java @@ -76,12 +76,12 @@ public class SplitStoreTest extends QpidBrokerTestCase public void testJsonConfigurationStoreWithPersistentMessageStore() throws Exception { - doTest(JsonFileConfigStore.TYPE, getTestProfileMessageStoreType()); + doTest(JsonFileConfigStore.TYPE, getTestProfileVirtualHostNodeType()); } public void testSeparateConfigurationAndMessageStoresOfTheSameType() throws Exception { - doTest(getTestProfileVirtualHostNodeType(), getTestProfileMessageStoreType()); + doTest(getTestProfileVirtualHostNodeType(), getTestProfileVirtualHostNodeType()); } private void configureAndStartBroker(String virtualHostNodeType, String virtualHostType) throws Exception diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java index 430fadc2f1..278de6cf41 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java @@ -24,6 +24,7 @@ import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import java.io.File; +import java.io.IOException; import java.security.PrivilegedAction; import java.util.ArrayList; import java.util.Collection; @@ -71,10 +72,13 @@ import org.apache.qpid.server.queue.StandardQueueImpl; import org.apache.qpid.server.txn.AutoCommitTransaction; import org.apache.qpid.server.txn.ServerTransaction; import org.apache.qpid.server.util.BrokerTestHelper; +import org.apache.qpid.server.virtualhost.TestMemoryVirtualHost; import org.apache.qpid.server.virtualhost.VirtualHostImpl; +import org.apache.qpid.server.virtualhostnode.AbstractStandardVirtualHostNode; import org.apache.qpid.server.virtualhostnode.FileBasedVirtualHostNode; import org.apache.qpid.test.utils.QpidTestCase; import org.apache.qpid.util.FileUtils; +import org.codehaus.jackson.map.ObjectMapper; /** * @@ -136,12 +140,21 @@ public class VirtualHostMessageStoreTest extends QpidTestCase nodeAttributes.put(ConfiguredObject.TYPE, getTestProfileVirtualHostNodeType()); nodeAttributes.put(FileBasedVirtualHostNode.STORE_PATH, _storePath); nodeAttributes.put(VirtualHostNode.NAME, nodeName); + _node = factory.create(VirtualHostNode.class, nodeAttributes, broker); _node.start(); final Map<String,Object> virtualHostAttributes = new HashMap<>(); virtualHostAttributes.put(VirtualHost.NAME, hostName); - + virtualHostAttributes.put(VirtualHost.NAME, hostName); + String bluePrint = getTestProfileVirtualHostNodeBlueprint(); + if (bluePrint == null) + { + bluePrint = "{type=\"" + TestMemoryVirtualHost.VIRTUAL_HOST_TYPE + "\"}"; + } + ObjectMapper objectMapper = new ObjectMapper(); + Map<String, Object> attrs = objectMapper.readValue(bluePrint, Map.class); + virtualHostAttributes.putAll(attrs); _node.createChild(VirtualHost.class, virtualHostAttributes, _node); _virtualHost = (VirtualHostImpl<?,?,?>)_node.getVirtualHost(); diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/VirtualHostRestTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/VirtualHostRestTest.java index 54dca95e9b..e287c9d5c1 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/VirtualHostRestTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/systest/rest/VirtualHostRestTest.java @@ -30,6 +30,7 @@ import java.util.Map; import javax.jms.Session; import javax.servlet.http.HttpServletResponse; +import org.apache.qpid.server.virtualhost.TestMemoryVirtualHost; import org.codehaus.jackson.JsonGenerationException; import org.codehaus.jackson.map.JsonMappingException; @@ -42,7 +43,6 @@ import org.apache.qpid.server.queue.LastValueQueue; import org.apache.qpid.server.queue.PriorityQueue; import org.apache.qpid.server.queue.SortedQueue; import org.apache.qpid.server.virtualhost.AbstractVirtualHost; -import org.apache.qpid.server.virtualhost.ProvidedStoreVirtualHost; import org.apache.qpid.server.virtualhostnode.FileBasedVirtualHostNode; import org.apache.qpid.util.FileUtils; @@ -540,7 +540,7 @@ public class VirtualHostRestTest extends QpidRestTestCase Map<String, Object> virtualhostData = new HashMap<>(); virtualhostData.put(VirtualHost.NAME, virtualHostName); - virtualhostData.put(VirtualHost.TYPE, ProvidedStoreVirtualHost.VIRTUAL_HOST_TYPE); + virtualhostData.put(VirtualHost.TYPE, TestMemoryVirtualHost.VIRTUAL_HOST_TYPE); getRestTestHelper().submitRequest("virtualhost/" + virtualHostName + "/" + virtualHostName, "PUT", diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java index 9b6abb1447..92d163f05a 100755 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java @@ -70,7 +70,6 @@ import org.apache.qpid.server.model.Protocol; import org.apache.qpid.server.model.VirtualHostNode; import org.apache.qpid.server.store.DurableConfigurationStore; import org.apache.qpid.server.store.MemoryConfigurationStore; -import org.apache.qpid.server.virtualhost.ProvidedStoreVirtualHost; import org.apache.qpid.server.virtualhostnode.AbstractStandardVirtualHostNode; import org.apache.qpid.server.virtualhostnode.FileBasedVirtualHostNode; import org.apache.qpid.url.URLSyntaxException; @@ -561,8 +560,8 @@ public class QpidBrokerTestCase extends QpidTestCase setSystemProperty("test.port.ssl"); setSystemProperty("test.port.alt"); setSystemProperty("test.port.alt.ssl"); - setSystemProperty("messagestore.type"); - + setSystemProperty("virtualhostnode.type"); + setSystemProperty("virtualhostnode.context.blueprint"); // Add all the specified system properties to QPID_OPTS if (!_propertiesSetForBroker.isEmpty()) @@ -872,7 +871,7 @@ public class QpidBrokerTestCase extends QpidTestCase { attributes.put(FileBasedVirtualHostNode.STORE_PATH, storeDir); } - final String blueprint = String.format("{ \"type\" : \"%s\" } }", ProvidedStoreVirtualHost.VIRTUAL_HOST_TYPE); + final String blueprint = getTestProfileVirtualHostNodeBlueprint(); attributes.put(ConfiguredObject.CONTEXT, Collections.singletonMap(AbstractStandardVirtualHostNode.VIRTUALHOST_BLUEPRINT_CONTEXT_VAR, blueprint)); diff --git a/qpid/java/test-profiles/CPPExcludes b/qpid/java/test-profiles/CPPExcludes index 8e48e77e07..9e9708bf3c 100755 --- a/qpid/java/test-profiles/CPPExcludes +++ b/qpid/java/test-profiles/CPPExcludes @@ -93,6 +93,7 @@ org.apache.qpid.server.store.VirtualHostMessageStoreTest#testQueuePersistence org.apache.qpid.server.store.VirtualHostMessageStoreTest#testDurableQueueRemoval org.apache.qpid.server.store.VirtualHostMessageStoreTest#testExchangePersistence org.apache.qpid.server.store.VirtualHostMessageStoreTest#testDurableExchangeRemoval +org.apache.qpid.server.store.VirtualHostMessageStoreTest#testQueueExchangeAndBindingCreation org.apache.qpid.server.store.DurableConfigurationStoreTest#* // CPP Broker does not follow the same Logging convention as the Java broker diff --git a/qpid/java/test-profiles/JavaJsonExcludes b/qpid/java/test-profiles/JavaJsonExcludes new file mode 100644 index 0000000000..9a5d87ca8a --- /dev/null +++ b/qpid/java/test-profiles/JavaJsonExcludes @@ -0,0 +1,24 @@ +// +// Licensed to the Apache Software Foundation (ASF) under one +// or more contributor license agreements. See the NOTICE file +// distributed with this work for additional information +// regarding copyright ownership. The ASF licenses this file +// to you under the Apache License, Version 2.0 (the +// "License"); you may not use this file except in compliance +// with the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, +// software distributed under the License is distributed on an +// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +// KIND, either express or implied. See the License for the +// specific language governing permissions and limitations +// under the License. +// + +org.apache.qpid.server.store.berkeleydb.* +org.apache.qpid.server.store.berkeleydb.replication.* +org.apache.qpid.server.store.SplitStoreTest#* +org.apache.qpid.systest.rest.VirtualHostNodeRestTest#testCreateAndDeleteVirtualHostNode +org.apache.qpid.server.BrokerStartupTest#testStartupWithNoConfig |
