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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
|
/*
*
* 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 javax.jms.Connection;
import org.apache.qpid.common.QpidProperties;
import java.util.HashMap;
import java.util.List;
import java.util.TreeSet;
public class ConnectionLoggingTest extends AbstractTestLogging
{
private static final String CONNECTION_PREFIX = "CON-";
// No explicit startup configuration is required for this test
// so no setUp() method
/**
* Description:
* When a new connection is made to the broker this must be logged.
*
* Input:
* 1. Running Broker
* 2. Connecting client
* Output:
* <date> CON-1001 : Open : Client ID {0}[ : Protocol Version : {1}] <version>
*
* Validation Steps:
* 1. The CON ID is correct
* 2. This is the first CON message for that Connection
*
* @throws Exception - if an error occurs
*/
public void testConnectionOpen() throws Exception
{
assertLoggingNotYetOccured(CONNECTION_PREFIX);
Connection connection = getConnection();
String clientid = connection.getClientID();
// Wait until opened
waitForMessage("CON-1001");
// Close the connection
connection.close();
// Wait to ensure that the desired message is logged
waitForMessage("CON-1002");
List<String> results = waitAndFindMatches("CON-1001");
// MESSAGE [con:1(/127.0.0.1:46927)] CON-1001 : Open
// MESSAGE [con:1(/127.0.0.1:46927)] CON-1001 : Open : Protocol Version : 0-9
// MESSAGE [con:1(/127.0.0.1:46927)] CON-1001 : Open : Client ID : clientid : Protocol Version : 0-9 : Client Version : 1.2.3_4
// MESSAGE [con:0(/127.0.0.1:46927)] CON-1002 : Close
HashMap<Integer, List<String>> connectionData = splitResultsOnConnectionID(results);
// Get the last Integer from keySet of the ConnectionData
int connectionID = new TreeSet<Integer>(connectionData.keySet()).last();
//Use just the data from the last connection for the test
results = connectionData.get(connectionID);
assertEquals("Unexpected CON-1001 messages count", 3, results.size());
String log = getLogMessage(results, 0);
// MESSAGE [con:1(/127.0.0.1:52540)] CON-1001 : Open
//1 & 2
validateMessageID("CON-1001",log);
// validate the last three CON-1001 messages.
// MESSAGE [con:1(/127.0.0.1:52540)] CON-1001 : Open : Client ID : clientid : Protocol Version : 0-9 : Client Version : 1.2.3_4
validateConnectionOpen(results, 0, true, true, clientid, true, QpidProperties.getReleaseVersion());
// MESSAGE [con:1(/127.0.0.1:52540)] CON-1001 : Open : Protocol Version : 0-9
validateConnectionOpen(results, 1, true, false, null, false, null);
// MESSAGE [con:1(/127.0.0.1:52540)] CON-1001 : Open
validateConnectionOpen(results, 2, false, false, null, false, null);
}
private void validateConnectionOpen(List<String> results, int positionFromEnd,
boolean protocolVersionPresent, boolean clientIdOptionPresent, String clientIdValue, boolean clientVersionPresent, String clientVersionValue)
{
String log = getLogMessageFromEnd(results, positionFromEnd);
validateMessageID("CON-1001",log);
assertEquals("unexpected Client ID option state", clientIdOptionPresent, fromMessage(log).contains("Client ID :"));
if(clientIdOptionPresent && clientIdValue != null)
{
assertTrue("Client ID value is not present: " + clientIdValue, fromMessage(log).contains(clientIdValue));
}
assertEquals("unexpected Protocol Version option state",
protocolVersionPresent, fromMessage(log).contains("Protocol Version :"));
//fixme there is no way currently to find out the negotiated protocol version
// The delegate is the versioned class ((AMQConnection)connection)._delegate
assertEquals("unexpected Client ID option state", clientVersionPresent, fromMessage(log).contains("Client Version :"));
if(clientVersionPresent && clientVersionValue != null)
{
assertTrue("Client version value is not present: " + clientVersionValue, fromMessage(log).contains(clientVersionValue));
}
}
/**
* Description:
* When a connected client closes the connection this will be logged as a CON-1002 message.
* Input:
*
* 1. Running Broker
* 2. Connected Client
* Output:
*
* <date> CON-1002 : Close
*
* Validation Steps:
* 3. The CON ID is correct
* 4. This must be the last CON message for the Connection
* 5. It must be preceded by a CON-1001 for this Connection
*/
public void testConnectionClose() throws Exception
{
assertLoggingNotYetOccured(CONNECTION_PREFIX);
Connection connection = getConnection();
// Wait until opened
waitForMessage("CON-1001");
// Close the conneciton
connection.close();
// Wait to ensure that the desired message is logged
waitForMessage("CON-1002");
List<String> results = findMatches(CONNECTION_PREFIX);
// Validation
// We should have at least four messages
assertTrue("CON messages not logged:" + results.size(), results.size() >= 4);
// Validate Close message occurs
String log = getLogMessageFromEnd(results, 0);
validateMessageID("CON-1002",log);
assertTrue("Message does not end with close:" + log, log.endsWith("Close"));
// Extract connection ID to validate there is a CON-1001 messasge for it
int closeConnectionID = getConnectionID(fromSubject(log));
assertTrue("Could not find connection id in CLOSE", closeConnectionID != -1);
//Previous log message should be the open
log = getLogMessageFromEnd(results, 1);
// MESSAGE [con:1(/127.0.0.1:52540)] CON-1001 : Open : Client ID : clientid : Protocol Version : 0-9
validateMessageID("CON-1001",log);
// Extract connection ID to validate it matches the CON-1002 messasge
int openConnectionID = getConnectionID(fromActor(log));
assertTrue("Could not find connection id in OPEN", openConnectionID != -1);
// Check connection ids match
assertEquals("Connection IDs do not match", closeConnectionID, openConnectionID);
}
}
|
