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
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
|
<html>
<head>
<title>Apache Qpid : MgmtC++</title>
<link rel="stylesheet" href="styles/site.css" type="text/css" />
<META http-equiv="Content-Type" content="text/html; charset=UTF-8">
</head>
<body>
<table class="pagecontent" border="0" cellpadding="0" cellspacing="0" width="100%" bgcolor="#ffffff">
<tr>
<td valign="top" class="pagebody">
<div class="pageheader">
<span class="pagetitle">
Apache Qpid : MgmtC++
</span>
</div>
<div class="pagesubheading">
This page last changed on Apr 15, 2008 by <font color="#0050B2">cctrieloff</font>.
</div>
<h2><a name="MgmtC%2B%2B-ManagingtheC%5CBroker"></a>Managing the C++ Broker</h2>
<p>There are quite a few ways to interact with the C++ broker. The command line tools<br/>
include:</p>
<ul>
<li>qpid-route - used to configure federation (a set of federated brokers)</li>
<li>qpid-config - used to configure queues, exchanges, bindings and list them etc</li>
<li>qpid-tool - used to view management information/statistics and call any management actions on the broker</li>
</ul>
<h3><a name="MgmtC%2B%2B-Usingqpidconfig"></a>Using qpid-config</h3>
<p>This utility can be used to create queues exchanges and bindings, both durable and transient. Always check for latest options by running --help command.</p>
<div class="code"><div class="codeContent">
<pre class="code-java">$ ./qpid-config --help
Usage: qpid-config OPTIONS
qpid-config OPTIONS exchanges filter-string
qpid-config OPTIONS queues filter-string
qpid-config OPTIONS add exchange <type> <name> AddExchangeOptions
qpid-config OPTIONS del exchange <name>
qpid-config OPTIONS add queue <name> AddQueueOptions
qpid-config OPTIONS del queue <name>
qpid-config OPTIONS bind <exchange-name> <queue-name> binding-key
qpid-config OPTIONS unbind <exchange-name> <queue-name> binding-key
Options:
-b [ --bindings ] Show bindings in queue or exchange list
-a [ --broker-addr ] Address (localhost) Address of qpidd broker
broker-addr is in the form: hostname | ip-address :<port>
ex: localhost, 10.1.1.7:10000, broker-host:10000
-s [ --spec-file] Path (/usr/share/amqp/amqp.0-10-preview.xml)
AMQP specification file
Add Queue Options:
--durable Queue is durable
Add Exchange Options:
--durable Exchange is durable</pre>
</div></div>
<p>Get the summary page</p>
<div class="code"><div class="codeContent">
<pre class="code-java">./qpid-config
Total Exchanges: 6
topic: 2
headers: 1
fanout: 1
direct: 2
Total Queues: 7
durable: 0
non-durable: 7</pre>
</div></div>
<p>List the queues</p>
<div class="code"><div class="codeContent">
<pre class="code-java">$ ./qpid-config queues
Store Size
Durable AutoDel Excl Bindings (files x file pages) Queue Name
===========================================================================================
N N N 1 pub_start
N N N 1 pub_done
N N N 1 sub_ready
N N N 1 sub_done
N N N 1 perftest0
N Y N 2 mgmt-3206ff16-fb29-4a30-82ea-e76f50dd7d15
N Y N 2 repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15
N Y N 2 mgmt-df06c7a6-4ce7-426a-9f66-da91a2a6a837
N Y N 2 repl-df06c7a6-4ce7-426a-9f66-da91a2a6a837</pre>
</div></div>
<p>List the exchanges with bindings</p>
<div class="code"><div class="codeContent">
<pre class="code-java">$ ./qpid-config -b exchanges
Exchange '' (direct)
bind pub_start => pub_start
bind pub_done => pub_done
bind sub_ready => sub_ready
bind sub_done => sub_done
bind perftest0 => perftest0
bind mgmt-3206ff16-fb29-4a30-82ea-e76f50dd7d15 => mgmt-3206ff16-fb29-4a30-82ea-e76f50dd7d15
bind repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15 => repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15
Exchange 'amq.direct' (direct)
bind repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15 => repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15
bind repl-df06c7a6-4ce7-426a-9f66-da91a2a6a837 => repl-df06c7a6-4ce7-426a-9f66-da91a2a6a837
bind repl-c55915c2-2fda-43ee-9410-b1c1cbb3e4ae => repl-c55915c2-2fda-43ee-9410-b1c1cbb3e4ae
Exchange 'amq.topic' (topic)
Exchange 'amq.fanout' (fanout)
Exchange 'amq.match' (headers)
Exchange 'qpid.management' (topic)
bind mgmt.# => mgmt-3206ff16-fb29-4a30-82ea-e76f50dd7d15</pre>
</div></div>
<h3><a name="MgmtC%2B%2B-Usingqpidroute"></a>Using qpid-route</h3>
<p>This utility is to create federated networks of brokers, This allows you for forward messages between brokers in a network. Think of it like an IP network and static routes are configured with direct exchanges, and dynamic routes configured with the topic exchanges. The '*' and '#' can be used to create IP masking type pattern as you would with IP address except you are using the topic names.</p>
<p>The utility thus looks much like iproute <img class="emoticon" src="./icons/emoticons/smile.gif" height="20" width="20" align="absmiddle" alt="" border="0"/></p>
<div class="code"><div class="codeContent">
<pre class="code-java">$ ./qpid-route --help
Usage: qpid-route OPTIONS add <dest-broker> <src-broker> <exchange> <routing-key>
qpid-route OPTIONS del <dest-broker> <src-broker> <exchange> <routing-key>
qpid-route OPTIONS list <dest-broker>
qpid-route OPTIONS flush <dest-broker>
Options:
-s [ --spec-file ] PATH (/usr/share/amqp/amqp.0-10.xml)
-v [ --verbose ] Verbose output
-q [ --quiet ] Quiet output, don't print duplicate warnings
dest-broker and src-broker are in the form: hostname | ip-address :<port>
ex: localhost, 10.1.1.7:10000, broker-host:10000</pre>
</div></div>
<p>A few examples:</p>
<div class="code"><div class="codeContent">
<pre class="code-java">./qpidd_route -v add host1 host2 hub1.topic hub2.topic.stock.buy
./qpidd_route -v add host1 host2 hub1.topic hub2.topic.stock.sell
./qpidd_route -v add host1 host2 hub1.topic 'hub2.topic.stock.#'
./qpidd_route -v add host1 host2 hub1.topic 'hub2.#'
./qpidd_route -v add host1 host2 hub1.topic 'hub2.topic.#'
./qpidd_route -v add host1 host2 hub1.topic 'hub2.global.#'</pre>
</div></div>
<h3><a name="MgmtC%2B%2B-Usingqpidtool"></a>Using qpid-tool</h3>
<p>This utility provided a telnet style interface to be able to view, list all stats and action<br/>
all the methods. Simple capture below. Best to just play with it and mail the list if you have<br/>
questions or want features added.</p>
<div class="code"><div class="codeContent">
<pre class="code-java">qpid:
qpid: help
Management Tool <span class="code-keyword">for</span> QPID
Commands:
list - Print summary of existing objects by class
list <className> - Print list of objects of the specified class
list <className> all - Print contents of all objects of specified class
list <className> active - Print contents of all non-deleted objects of specified class
list <list-of-IDs> - Print contents of one or more objects (infer className)
list <className> <list-of-IDs> - Print contents of one or more objects
list is space-separated, ranges may be specified (i.e. 1004-1010)
call <ID> <methodName> <args> - Invoke a method on an object
schema - Print summary of object classes seen on the target
schema <className> - Print details of an object class
set time-format <span class="code-object">short</span> - Select <span class="code-object">short</span> timestamp format (<span class="code-keyword">default</span>)
set time-format <span class="code-object">long</span> - Select <span class="code-object">long</span> timestamp format
quit or ^D - Exit the program
qpid: list
Management <span class="code-object">Object</span> Types:
ObjectType Active Deleted
================================
qpid.binding 21 0
qpid.broker 1 0
qpid.client 1 0
qpid.exchange 6 0
qpid.queue 13 0
qpid.session 4 0
qpid.system 1 0
qpid.vhost 1 0
qpid: list qpid.system
Objects of type qpid.system
ID Created Destroyed Index
==================================
1000 21:00:02 - host
qpid: list 1000
<span class="code-object">Object</span> of type qpid.system: (last sample time: 21:26:02)
Type Element 1000
=======================================================
config sysId host
config osName Linux
config nodeName localhost.localdomain
config release 2.6.24.4-64.fc8
config version #1 SMP Sat Mar 29 09:15:49 EDT 2008
config machine x86_64
qpid: schema queue
Schema <span class="code-keyword">for</span> class 'qpid.queue':
Element Type Unit Access Notes Description
===================================================================================================================
vhostRef reference ReadCreate index
name <span class="code-object">short</span>-string ReadCreate index
durable <span class="code-object">boolean</span> ReadCreate
autoDelete <span class="code-object">boolean</span> ReadCreate
exclusive <span class="code-object">boolean</span> ReadCreate
arguments field-table ReadOnly Arguments supplied in queue.declare
storeRef reference ReadOnly Reference to persistent queue (<span class="code-keyword">if</span> durable)
msgTotalEnqueues uint64 message Total messages enqueued
msgTotalDequeues uint64 message Total messages dequeued
msgTxnEnqueues uint64 message Transactional messages enqueued
msgTxnDequeues uint64 message Transactional messages dequeued
msgPersistEnqueues uint64 message Persistent messages enqueued
msgPersistDequeues uint64 message Persistent messages dequeued
msgDepth uint32 message Current size of queue in messages
msgDepthHigh uint32 message Current size of queue in messages (High)
msgDepthLow uint32 message Current size of queue in messages (Low)
byteTotalEnqueues uint64 octet Total messages enqueued
byteTotalDequeues uint64 octet Total messages dequeued
byteTxnEnqueues uint64 octet Transactional messages enqueued
byteTxnDequeues uint64 octet Transactional messages dequeued
bytePersistEnqueues uint64 octet Persistent messages enqueued
bytePersistDequeues uint64 octet Persistent messages dequeued
byteDepth uint32 octet Current size of queue in bytes
byteDepthHigh uint32 octet Current size of queue in bytes (High)
byteDepthLow uint32 octet Current size of queue in bytes (Low)
enqueueTxnStarts uint64 transaction Total enqueue transactions started
enqueueTxnCommits uint64 transaction Total enqueue transactions committed
enqueueTxnRejects uint64 transaction Total enqueue transactions rejected
enqueueTxnCount uint32 transaction Current pending enqueue transactions
enqueueTxnCountHigh uint32 transaction Current pending enqueue transactions (High)
enqueueTxnCountLow uint32 transaction Current pending enqueue transactions (Low)
dequeueTxnStarts uint64 transaction Total dequeue transactions started
dequeueTxnCommits uint64 transaction Total dequeue transactions committed
dequeueTxnRejects uint64 transaction Total dequeue transactions rejected
dequeueTxnCount uint32 transaction Current pending dequeue transactions
dequeueTxnCountHigh uint32 transaction Current pending dequeue transactions (High)
dequeueTxnCountLow uint32 transaction Current pending dequeue transactions (Low)
consumers uint32 consumer Current consumers on queue
consumersHigh uint32 consumer Current consumers on queue (High)
consumersLow uint32 consumer Current consumers on queue (Low)
bindings uint32 binding Current bindings
bindingsHigh uint32 binding Current bindings (High)
bindingsLow uint32 binding Current bindings (Low)
unackedMessages uint32 message Messages consumed but not yet acked
unackedMessagesHigh uint32 message Messages consumed but not yet acked (High)
unackedMessagesLow uint32 message Messages consumed but not yet acked (Low)
messageLatencySamples delta-time nanosecond Broker latency through <span class="code-keyword">this</span> queue (Samples)
messageLatencyMin delta-time nanosecond Broker latency through <span class="code-keyword">this</span> queue (Min)
messageLatencyMax delta-time nanosecond Broker latency through <span class="code-keyword">this</span> queue (Max)
messageLatencyAverage delta-time nanosecond Broker latency through <span class="code-keyword">this</span> queue (Average)
Method 'purge' Discard all messages on queue
qpid: list queue
Objects of type qpid.queue
ID Created Destroyed Index
===========================================================================
1012 21:08:13 - 1002.pub_start
1014 21:08:13 - 1002.pub_done
1016 21:08:13 - 1002.sub_ready
1018 21:08:13 - 1002.sub_done
1020 21:08:13 - 1002.perftest0
1038 21:09:08 - 1002.mgmt-3206ff16-fb29-4a30-82ea-e76f50dd7d15
1040 21:09:08 - 1002.repl-3206ff16-fb29-4a30-82ea-e76f50dd7d15
1046 21:09:32 - 1002.mgmt-df06c7a6-4ce7-426a-9f66-da91a2a6a837
1048 21:09:32 - 1002.repl-df06c7a6-4ce7-426a-9f66-da91a2a6a837
1054 21:10:01 - 1002.mgmt-c55915c2-2fda-43ee-9410-b1c1cbb3e4ae
1056 21:10:01 - 1002.repl-c55915c2-2fda-43ee-9410-b1c1cbb3e4ae
1063 21:26:00 - 1002.mgmt-8d621997-6356-48c3-acab-76a37081d0f3
1065 21:26:00 - 1002.repl-8d621997-6356-48c3-acab-76a37081d0f3
qpid: list 1020
<span class="code-object">Object</span> of type qpid.queue: (last sample time: 21:26:02)
Type Element 1020
==========================================================================
config vhostRef 1002
config name perftest0
config durable False
config autoDelete False
config exclusive False
config arguments {'qpid.max_size': 0, 'qpid.max_count': 0}
config storeRef NULL
inst msgTotalEnqueues 500000 messages
inst msgTotalDequeues 500000
inst msgTxnEnqueues 0
inst msgTxnDequeues 0
inst msgPersistEnqueues 0
inst msgPersistDequeues 0
inst msgDepth 0
inst msgDepthHigh 0
inst msgDepthLow 0
inst byteTotalEnqueues 512000000 octets
inst byteTotalDequeues 512000000
inst byteTxnEnqueues 0
inst byteTxnDequeues 0
inst bytePersistEnqueues 0
inst bytePersistDequeues 0
inst byteDepth 0
inst byteDepthHigh 0
inst byteDepthLow 0
inst enqueueTxnStarts 0 transactions
inst enqueueTxnCommits 0
inst enqueueTxnRejects 0
inst enqueueTxnCount 0
inst enqueueTxnCountHigh 0
inst enqueueTxnCountLow 0
inst dequeueTxnStarts 0
inst dequeueTxnCommits 0
inst dequeueTxnRejects 0
inst dequeueTxnCount 0
inst dequeueTxnCountHigh 0
inst dequeueTxnCountLow 0
inst consumers 0 consumers
inst consumersHigh 0
inst consumersLow 0
inst bindings 1 binding
inst bindingsHigh 1
inst bindingsLow 1
inst unackedMessages 0 messages
inst unackedMessagesHigh 0
inst unackedMessagesLow 0
inst messageLatencySamples 0
inst messageLatencyMin 0
inst messageLatencyMax 0
inst messageLatencyAverage 0
qpid:</pre>
</div></div>
<p>You get the idea... have fun!</p>
</td>
</tr>
</table>
<table border="0" cellpadding="0" cellspacing="0" width="100%">
<tr>
<td height="12" background="border/border_bottom.gif"><img src="border/spacer.gif" width="1" height="1" border="0"/></td>
</tr>
<tr>
<td align="center"><font color="grey">Document generated by Confluence on Apr 22, 2008 02:47</font></td>
</tr>
</table>
</body>
</html>
|
