1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*
* 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 java.util.Arrays;
import java.util.List;
import junit.framework.AssertionFailedError;
import org.apache.qpid.server.configuration.ServerConfiguration;
/**
* Virtualhost Test Cases
* The virtualhost test suite validates that the follow log messages as specified in the Functional Specification.
* <p/>
* This suite of tests validate that the management console messages occur correctly and according to the following format:
* <p/>
* VHT-1001 : Created : <name>
* VHT-1002 : Work directory : <path>
* VHT-1003 : Closed
*/
public class VirtualHostLoggingTest extends AbstractTestLogging
{
private static final String VHT_PREFIX = "VHT-";
/**
* Description:
* Testing can be performed using the default configuration. The goal is to validate that for each virtualhost defined in the configuration file a VHT-1001 Created message is provided.
* Input:
* The default configuration file
* Output:
* <p/>
* <date> VHT-1001 : Created : <name>
* Validation Steps:
* <p/>
* The VHT ID is correct
* A VHT-1001 is printed for each virtualhost defined in the configuration file.
* This must be the first message for the specified virtualhost.
*
* @throws Exception caused by broker startup
*/
public void testVirtualhostCreation() throws Exception
{
//Wait for the correct VHT message to arrive.
waitForMessage(VHT_PREFIX + "1001");
//Validate each vhost logs a creation
List<String> results = findMatches(VHT_PREFIX + "1001");
try
{
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++)
{
// Retrieve the vhostname from the log entry message 'Created : <vhostname>'
String result = getLogMessage(results, index);
String vhostName = getMessageString(fromMessage(result)).split(" ")[2];
assertTrue("Virtualhost named in log not found in config file:" + vhostName + ":" + vhosts, vhosts.contains(vhostName));
}
}
catch (AssertionFailedError afe)
{
dumpLogs(results, _monitor);
throw afe;
}
}
/**
* Description:
* Testing can be performed using the default configuration. During broker shutdown a VHT-1002 Closed message will be printed for each of the configured virtualhosts. For every virtualhost that was started a close must be logged. After the close message has been printed no further logging will be performed by this virtualhost.
* Input:
* The default configuration file
* Output:
* <p/>
* <date> VHT-1002 : Closed
* Validation Steps:
* <p/>
* The VHT ID is correct
* This is the last VHT message for the given virtualhost.
*
* @throws Exception caused by broker startup
*/
public void testVirtualhostClosure() throws Exception
{
stopBroker();
// Wait for the correct VHT message to arrive.
waitForMessage(VHT_PREFIX + "1002");
// Validate each vhost logs a closure
List<String> results = findMatches(VHT_PREFIX + "1002");
try
{
// Load VirtualHost list from file.
ServerConfiguration configuration = new ServerConfiguration(_configFile);
configuration.initialise();
List<String> vhosts = Arrays.asList(configuration.getVirtualHosts());
assertEquals("Each vhost did not close their store.", vhosts.size(), results.size());
}
catch (AssertionFailedError afe)
{
dumpLogs(results, _monitor);
throw afe;
}
}
}
|
