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
|
/*
* 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.management.jmx;
import org.apache.qpid.exchange.ExchangeDefaults;
import org.apache.qpid.management.common.mbeans.ManagedBroker;
import org.apache.qpid.management.common.mbeans.ManagedExchange;
import org.apache.qpid.management.common.mbeans.ManagedQueue;
import org.apache.qpid.server.queue.AMQQueueFactory;
import org.apache.qpid.test.utils.JMXTestUtils;
import org.apache.qpid.test.utils.QpidBrokerTestCase;
import javax.management.MBeanException;
import javax.management.ObjectName;
import java.util.Collections;
import java.util.Map;
/**
* Tests the JMX API for the Managed Broker.
*
*/
public class ManagedBrokerMBeanTest extends QpidBrokerTestCase
{
/**
* Test virtual host
*/
private static final String VIRTUAL_HOST = "test";
/**
* Test exchange type
*/
private static final String EXCHANGE_TYPE = "topic";
/**
* JMX helper.
*/
private JMXTestUtils _jmxUtils;
private ManagedBroker _managedBroker;
public void setUp() throws Exception
{
_jmxUtils = new JMXTestUtils(this);
_jmxUtils.setUp();
super.setUp();
_jmxUtils.open();
_managedBroker = _jmxUtils.getManagedBroker(VIRTUAL_HOST);
}
public void tearDown() throws Exception
{
if (_jmxUtils != null)
{
_jmxUtils.close();
}
super.tearDown();
}
/**
* Tests queue creation/deletion also verifying the automatic binding to the default exchange.
*/
public void testCreateQueueAndDeletion() throws Exception
{
final String queueName = getTestQueueName();
final ManagedExchange defaultExchange = _jmxUtils.getManagedExchange(ExchangeDefaults.DEFAULT_EXCHANGE_NAME.asString());
// Check that bind does not exist before queue creation
assertFalse("Binding to " + queueName + " should not exist in default exchange before queue creation",
defaultExchange.bindings().containsKey(new String[] {queueName}));
_managedBroker.createNewQueue(queueName, "testowner", true);
// Ensure the queue exists
assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName("test", queueName));
assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));
// Now verify that the default exchange has been bound.
assertTrue("Binding to " + queueName + " should exist in default exchange after queue creation",
defaultExchange.bindings().containsKey(new String[] {queueName}));
// Now delete the queue
_managedBroker.deleteQueue(queueName);
// Finally ensure that the binding has been removed.
assertFalse("Binding to " + queueName + " should not exist in default exchange after queue deletion",
defaultExchange.bindings().containsKey(new String[] {queueName}));
}
/**
* Tests exchange creation/deletion via JMX API.
*/
public void testCreateExchangeAndUnregister() throws Exception
{
String exchangeName = getTestName();
_managedBroker.createNewExchange(exchangeName, "topic", true);
String queryString = "org.apache.qpid:type=VirtualHost.Exchange,VirtualHost="
+ ObjectName.quote(VIRTUAL_HOST) + ",name=" + ObjectName.quote(exchangeName) + ",ExchangeType="
+ EXCHANGE_TYPE;
ManagedExchange exchange = _jmxUtils.getManagedObject(ManagedExchange.class, queryString);
assertNotNull("Exchange should exist", exchange);
_managedBroker.unregisterExchange(exchangeName);
assertFalse("Exchange should have been removed", _jmxUtils.isManagedObjectExist(queryString));
}
/**
* Tests that it is disallowed to unregister the default exchange.
*/
public void testUnregisterOfDefaultExchangeDisallowed() throws Exception
{
String defaultExchangeName = ExchangeDefaults.DEFAULT_EXCHANGE_NAME.asString();
try
{
_managedBroker.unregisterExchange(defaultExchangeName);
fail("Exception not thrown");
}
catch (MBeanException mbe)
{
// PASS
assertEquals("Error in unregistering exchange " + defaultExchangeName, mbe.getMessage());
assertTrue(mbe.getCause().getMessage().contains("Cannot unregister the default exchange"));
}
final ManagedExchange defaultExchange = _jmxUtils.getManagedExchange(defaultExchangeName);
assertNotNull("Exchange should exist", defaultExchange);
}
/**
* Tests queue creation with {@link AMQQueueFactory#X_QPID_MAXIMUM_DELIVERY_COUNT} argument. Also tests
* that the attribute is exposed correctly through {@link ManagedQueue#getMaximumDeliveryCount()}.
*/
public void testCreateQueueWithMaximumDeliveryCountSet() throws Exception
{
final String queueName = getName();
final ManagedBroker managedBroker = _jmxUtils.getManagedBroker(VIRTUAL_HOST);
final Integer deliveryCount = 1;
final Map<String, Object> args = Collections.singletonMap(AMQQueueFactory.X_QPID_MAXIMUM_DELIVERY_COUNT, (Object)deliveryCount);
managedBroker.createNewQueue(queueName, "testowner", true, args);
// Ensure the queue exists
assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName("test", queueName));
assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));
final ManagedQueue managedQueue = _jmxUtils.getManagedQueue(queueName);
assertEquals("Unexpected maximum delivery count", deliveryCount, managedQueue.getMaximumDeliveryCount());
}
}
|
