diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/server/logging/MemoryMessageStoreLoggingTest.java')
-rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/logging/MemoryMessageStoreLoggingTest.java | 186 |
1 files changed, 0 insertions, 186 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/logging/MemoryMessageStoreLoggingTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/logging/MemoryMessageStoreLoggingTest.java deleted file mode 100644 index e6e1196cc6..0000000000 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/logging/MemoryMessageStoreLoggingTest.java +++ /dev/null @@ -1,186 +0,0 @@ -/* -* -* 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. -* -*/ -package org.apache.qpid.server.logging; - -import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.logging.subjects.AbstractTestLogSubject; -import org.apache.qpid.util.LogMonitor; - -import java.util.Arrays; -import java.util.List; - -/** - * The MessageStore test suite validates that the follow log messages as - * specified in the Functional Specification. - * - * This suite of tests validate that the MessageStore messages occur correctly - * and according to the following format: - * - * MST-1001 : Created : <name> - * MST-1003 : Closed - * - * NOTE: Only for Persistent Stores - * MST-1002 : Store location : <path> - * MST-1004 : Recovery Start [: <queue.name>] - * MST-1005 : Recovered <count> messages for queue <queue.name> - * MST-1006 : Recovery Complete [: <queue.name>] - */ -public class MemoryMessageStoreLoggingTest extends AbstractTestLogging -{ - protected static final String MESSAGES_STORE_PREFIX = "MST-"; - - public void setUp() throws Exception - { - //We explicitly do not call super.setUp as starting up the broker is - //part of the test case. - // So we have to make the new Log Monitor here - - _monitor = new LogMonitor(_outputFile); - } - - /** - * Description: - * During Virtualhost startup a MessageStore will be created. The first MST - * message that must be logged is the MST-1001 MessageStore creation. - * Input: - * Default configuration - * Output: - * <date> MST-1001 : Created : <name> - * - * Validation Steps: - * - * 1. The MST ID is correct - * 2. The <name> is the correct MessageStore type as specified in the Default configuration - * - * @throws Exception caused by broker startup - */ - public void testMessageStoreCreation() throws Exception - { - assertLoggingNotYetOccured(MESSAGES_STORE_PREFIX); - - super.setUp(); - - List<String> results = waitAndFindMatches(MESSAGES_STORE_PREFIX); - - // Validation - - assertTrue("MST messages not logged", results.size() > 0); - - String log = getLogMessage(results, 0); - //1 - assertEquals("MST-1001 is not the first MST message", "MST-1001", getMessageID(fromMessage(log))); - - //Validate each vhost logs a creation - results = waitAndFindMatches("MST-1001"); - - // Load VirtualHost list from file. - List<String> vhosts = Arrays.asList(getServerConfig().getVirtualHosts()); - - assertEquals("Each vhost did not create a store.", vhosts.size(), results.size()); - - for (int index = 0; index < results.size(); index++) - { - String result = getLogMessage(results, index); - - // getSlice will return extract the vhost from vh(/test) -> '/test' - // so remove the '/' to get the name - String vhostName = AbstractTestLogSubject.getSlice("vh", result).substring(1); - - // Get the store class used in the configuration for the virtualhost. - String fullStoreName = getServerConfig().getVirtualHostConfig(vhostName).getMessageStoreClass(); - - // Get the Simple class name from the expected class name of o.a.q.s.s.MMS - String storeName = fullStoreName.substring(fullStoreName.lastIndexOf(".") + 1); - - assertTrue("MST-1001 does not contains correct store name:" - + storeName + ":" + result, getMessageString(result).endsWith(storeName)); - - assertEquals("The store name does not match expected value", - storeName, AbstractTestLogSubject.getSlice("ms", fromSubject(result))); - } - } - - /** - * Description: - * During shutdown the MessageStore will also cleanly close. When this has - * completed a MST-1003 closed message will be logged. No further messages - * from this MessageStore will be logged after this message. - * - * Input: - * Default configuration - * Output: - * <date> MST-1003 : Closed - * - * Validation Steps: - * - * 1. The MST ID is correct - * 2. This is teh last log message from this MessageStore - * - * @throws Exception caused by broker startup - */ - public void testMessageStoreClose() throws Exception - { - assertLoggingNotYetOccured(MESSAGES_STORE_PREFIX); - - super.setUp(); - - //Stop the broker so we get the close messages. - stopBroker(); - - List<String> results = waitAndFindMatches(MESSAGES_STORE_PREFIX); - - // Validation - - assertTrue("MST messages not logged", results.size() > 0); - - // Load VirtualHost list from file. - ServerConfiguration configuration = new ServerConfiguration(_configFile); - configuration.initialise(); - List<String> vhosts = Arrays.asList(configuration.getVirtualHosts()); - - //Validate each vhost logs a creation - results = waitAndFindMatches("MST-1003"); - - assertEquals("Each vhost did not close its store.", vhosts.size(), results.size()); - - for (int index = 0; index < results.size(); index++) - { - String result = getLogMessage(results, index); - - // getSlice will return extract the vhost from vh(/test) -> '/test' - // so remove the '/' to get the name - String vhostName = AbstractTestLogSubject.getSlice("vh", result).substring(1); - - // Get the store class used in the configuration for the virtualhost. - String fullStoreName = configuration.getVirtualHostConfig(vhostName).getMessageStoreClass(); - - // Get the Simple class name from the expected class name of o.a.q.s.s.MMS - String storeName = fullStoreName.substring(fullStoreName.lastIndexOf(".") + 1); - - assertEquals("MST-1003 does not close:", - "Closed", getMessageString(result)); - - assertEquals("The store name does not match expected value", - storeName, AbstractTestLogSubject.getSlice("ms", fromSubject(result))); - } - } - -} |