forked from kgiusti/oslo-messaging-clients
-
Notifications
You must be signed in to change notification settings - Fork 0
/
oslo-addresses.txt
243 lines (208 loc) · 21.4 KB
/
oslo-addresses.txt
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
./my-server.py &
Running server, name=my-server-name exchange=my-exchange topic=my-topic namespace=my-namespace
Created connection <qpid.messaging.endpoints.Connection instance at 0x1d0d3f8>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1d0d440>
Created session <Session df3496d7-4425-4e41-b91d-adc6fa9ce120:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1d0d440>
Creating receiver for address:
'openstack/my-topic ; {"node": {"x-declare": {"auto-delete": true, "durable": true},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": false, "exclusive": false, "durable": false},
"durable": true, "name": "my-topic"}}' on session '<Session df3496d7-4425-4e41-b91d-adc6fa9ce120:0>'
Creating receiver for address:
'openstack/my-topic.my-server-name ; {"node": {"x-declare": {"auto-delete": true, "durable": true},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": false, "exclusive": false, "durable": false},
"durable": true, "name": "my-topic.my-server-name"}}' on session '<Session df3496d7-4425-4e41-b91d-adc6fa9ce120:0>'
Creating receiver for address:
'my-topic_fanout ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "fanout"},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": true, "exclusive": true, "durable": false},
"durable": true,
"name": "my-topic_fanout_790d07a871094e9fa929da2d2ecf3888"}}' on session '<Session df3496d7-4425-4e41-b91d-adc6fa9ce120:0>'
./my-server.py --server my-other-server &
(pyenv)[kgiusti@t530 work (master)]$ Running server, name=my-other-server exchange=my-exchange topic=my-topic namespace=my-namespace
Created connection <qpid.messaging.endpoints.Connection instance at 0x14e03f8>
Created connection <qpid.messaging.endpoints.Connection instance at 0x14e0440>
Created session <Session ccc130f3-4cc8-4850-9637-1b0dbf499e37:0> on connection <qpid.messaging.endpoints.Connection instance at 0x14e0440>
Creating receiver for address:
'openstack/my-topic ; {"node": {"x-declare": {"auto-delete": true, "durable": true},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": false, "exclusive": false, "durable": false},
"durable": true, "name": "my-topic"}}' on session '<Session ccc130f3-4cc8-4850-9637-1b0dbf499e37:0>'
Creating receiver for address:
'openstack/my-topic.my-other-server ; {"node": {"x-declare": {"auto-delete": true, "durable": true},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": false, "exclusive": false, "durable": false},
"durable": true,
"name": "my-topic.my-other-server"}}' on session '<Session ccc130f3-4cc8-4850-9637-1b0dbf499e37:0>'
Creating receiver for address:
'my-topic_fanout ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "fanout"},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"auto-delete": true, "exclusive": true, "durable": false},
"durable": true,
"name": "my-topic_fanout_2a86fac82e014295b4648bea84f5351f"}}' on session '<Session ccc130f3-4cc8-4850-9637-1b0dbf499e37:0>'
./my-client.py my-topic common arg1 arg2
Calling server on topic my-topic, server=None exchange=my-exchange namespace=my-namespace fanout=None
Method=common, args={'arg1': 'arg2'}
Created connection <qpid.messaging.endpoints.Connection instance at 0x1aedf38>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1aedf80>
Created session <Session 3fe90e1d-7666-4a7d-bb6e-648244e8e830:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1aedf80>
Creating receiver for address:
'reply_905ca1ad8a8447fdb13ebf95f3b42fa3/reply_905ca1ad8a8447fdb13ebf95f3b42fa3 ;
{"node": {"x-declare": {"auto-delete": true, "durable": true, "type": "direct"},
"type": "topic"},
"create": "always",
"link": {"x-declare": {"exclusive": true, "auto-delete": false, "durable": false},
"durable": true,
"name": "reply_905ca1ad8a8447fdb13ebf95f3b42fa3"}}' on session '<Session 3fe90e1d-7666-4a7d-bb6e-648244e8e830:0>'
Created connection <qpid.messaging.endpoints.Connection instance at 0x1b701b8>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1b70290>
Created session <Session 2ef1dc7b-7c02-488b-bbe9-ae2aa6094961:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1b70290>
Creating sender for address:
'openstack/my-topic ; {"node": {"x-declare": {"auto-delete": true, "durable": false},
"type": "topic"},
"create": "always"}' on session '<Session 2ef1dc7b-7c02-488b-bbe9-ae2aa6094961:0>'
reset session <Session 2ef1dc7b-7c02-488b-bbe9-ae2aa6094961:1> on connection <qpid.messaging.endpoints.Connection instance at 0x1b70290>
my-server-name::TestEndpoint01::common( ctxt={'application': u'my-client', 'cast': None, 'time': u'Mon Sep 16 10:23:55 2013'} arg={u'arg1': u'arg2'} ) called!!!
Created connection <qpid.messaging.endpoints.Connection instance at 0x1d88a70>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1d88f80>
Created session <Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1d88f80>
Creating sender for address:
'reply_905ca1ad8a8447fdb13ebf95f3b42fa3 ;
{"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"},
"type": "topic"},
"create": "always"}' on session '<Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:0>'
Creating sender for address:
'reply_905ca1ad8a8447fdb13ebf95f3b42fa3 ;
{"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"},
"type": "topic"},
"create": "always"}' on session '<Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:0>'
reset session <Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:1> on connection <qpid.messaging.endpoints.Connection instance at 0x1d88f80>
Return value=None
./my-client.py --fanout my-topic common arg1 arg2
Calling server on topic my-topic, server=None exchange=my-exchange namespace=my-namespace fanout=True
Method=common, args={'arg1': 'arg2'}
Created connection <qpid.messaging.endpoints.Connection instance at 0x1781f38>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1781f80>
Created session <Session 52109711-da83-46da-bcc5-66da5184f7c3:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1781f80>
Creating receiver for address 'reply_c31daeafc83a4f6eb83adb14d190494f/reply_c31daeafc83a4f6eb83adb14d190494f ; {"node": {"x-declare": {"auto-delete": true, "durable": true, "type": "direct"}, "type": "topic"}, "create": "always", "link": {"x-declare": {"exclusive": true, "auto-delete": false, "durable": false}, "durable": true, "name": "reply_c31daeafc83a4f6eb83adb14d190494f"}}' on session '<Session 52109711-da83-46da-bcc5-66da5184f7c3:0>'
Created connection <qpid.messaging.endpoints.Connection instance at 0x18050e0>
Created connection <qpid.messaging.endpoints.Connection instance at 0x1805248>
Created session <Session c9556f6e-6862-453b-9c53-2d86e3cf1e22:0> on connection <qpid.messaging.endpoints.Connection instance at 0x1805248>
Creating sender for address 'my-topic_fanout ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "fanout"}, "type": "topic"}, "create": "always"}' on session '<Session c9556f6e-6862-453b-9c53-2d86e3cf1e22:0>'
reset session <Session c9556f6e-6862-453b-9c53-2d86e3cf1e22:1> on connection <qpid.messaging.endpoints.Connection instance at 0x1805248>
my-other-server::TestEndpoint01::common( ctxt={'application': u'my-client', 'cast': None, 'time': u'Mon Sep 16 10:24:02 2013'} arg={u'arg1': u'arg2'} ) called!!!
my-server-name::TestEndpoint01::common( ctxt={'application': u'my-client', 'cast': None, 'time': u'Mon Sep 16 10:24:02 2013'} arg={u'arg1': u'arg2'} ) called!!!
Creating sender for address 'reply_c31daeafc83a4f6eb83adb14d190494f ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:1>'
Created connection <qpid.messaging.endpoints.Connection instance at 0x155abd8>
Created connection <qpid.messaging.endpoints.Connection instance at 0x155aea8>
Created session <Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:0> on connection <qpid.messaging.endpoints.Connection instance at 0x155aea8>
Creating sender for address 'reply_c31daeafc83a4f6eb83adb14d190494f ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:0>'
Creating sender for address 'reply_c31daeafc83a4f6eb83adb14d190494f ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:1>'
Creating sender for address 'reply_c31daeafc83a4f6eb83adb14d190494f ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:0>'
reset session <Session 7648b0bb-93d6-4daa-998c-438ae8a5976b:2> on connection <qpid.messaging.endpoints.Connection instance at 0x1d88f80>
Return value=None
reset session <Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:1> on connection <qpid.messaging.endpoints.Connection instance at 0x155aea8>
(pyenv)[kgiusti@t530 work (master)]$
(pyenv)[kgiusti@t530 work (master)]$ ./my-client.py --server my-other-server my-topic common arg1 arg2
Calling server on topic my-topic, server=my-other-server exchange=my-exchange namespace=my-namespace fanout=None
Method=common, args={'arg1': 'arg2'}
Created connection <qpid.messaging.endpoints.Connection instance at 0x2d31f38>
Created connection <qpid.messaging.endpoints.Connection instance at 0x2d31f80>
Created session <Session 9244f578-e6d5-472f-9ec4-c6b004b178cd:0> on connection <qpid.messaging.endpoints.Connection instance at 0x2d31f80>
Creating receiver for address 'reply_9dc86f831d104e96ae226677ca360897/reply_9dc86f831d104e96ae226677ca360897 ; {"node": {"x-declare": {"auto-delete": true, "durable": true, "type": "direct"}, "type": "topic"}, "create": "always", "link": {"x-declare": {"exclusive": true, "auto-delete": false, "durable": false}, "durable": true, "name": "reply_9dc86f831d104e96ae226677ca360897"}}' on session '<Session 9244f578-e6d5-472f-9ec4-c6b004b178cd:0>'
Created connection <qpid.messaging.endpoints.Connection instance at 0x2db50e0>
Created connection <qpid.messaging.endpoints.Connection instance at 0x2db5248>
Created session <Session 1fd2316d-9536-4700-96f9-27136a50045c:0> on connection <qpid.messaging.endpoints.Connection instance at 0x2db5248>
Creating sender for address 'openstack/my-topic.my-other-server ; {"node": {"x-declare": {"auto-delete": true, "durable": false}, "type": "topic"}, "create": "always"}' on session '<Session 1fd2316d-9536-4700-96f9-27136a50045c:0>'
reset session <Session 1fd2316d-9536-4700-96f9-27136a50045c:1> on connection <qpid.messaging.endpoints.Connection instance at 0x2db5248>
my-other-server::TestEndpoint01::common( ctxt={'application': u'my-client', 'cast': None, 'time': u'Mon Sep 16 10:24:07 2013'} arg={u'arg1': u'arg2'} ) called!!!
Creating sender for address 'reply_9dc86f831d104e96ae226677ca360897 ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:1>'
Creating sender for address 'reply_9dc86f831d104e96ae226677ca360897 ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:1>'
Return value=None
reset session <Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:2> on connection <qpid.messaging.endpoints.Connection instance at 0x155aea8>
(pyenv)[kgiusti@t530 work (master)]$
(pyenv)[kgiusti@t530 work (master)]$ ./my-client.py --cast my-topic common arg1 arg2
Calling server on topic my-topic, server=None exchange=my-exchange namespace=my-namespace fanout=None
Method=common, args={'arg1': 'arg2'}
Created connection <qpid.messaging.endpoints.Connection instance at 0x1504fc8>
Created connection <qpid.messaging.endpoints.Connection instance at 0x150b050>
Created session <Session 0e254a30-ca81-4428-a252-2b65c9e9625d:0> on connection <qpid.messaging.endpoints.Connection instance at 0x150b050>
Creating sender for address 'openstack/my-topic ; {"node": {"x-declare": {"auto-delete": true, "durable": false}, "type": "topic"}, "create": "always"}' on session '<Session 0e254a30-ca81-4428-a252-2b65c9e9625d:0>'
my-other-server::TestEndpoint01::common( ctxt={'application': u'my-client', 'cast': True, 'time': u'Mon Sep 16 10:24:13 2013'} arg={u'arg1': u'arg2'} ) called!!!
reset session <Session 0e254a30-ca81-4428-a252-2b65c9e9625d:1> on connection <qpid.messaging.endpoints.Connection instance at 0x150b050>
Creating sender for address 'None ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:2>'
Creating sender for address 'None ; {"node": {"x-declare": {"auto-delete": true, "durable": false, "type": "direct"}, "type": "topic"}, "create": "always"}' on session '<Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:2>'
reset session <Session 6e5c29ae-315a-452a-8ffd-42a6b4edf513:3> on connection <qpid.messaging.endpoints.Connection instance at 0x155aea8>
(pyenv)[kgiusti@t530 work (master)]$
(pyenv)[kgiusti@t530 work (master)]$
(pyenv)[kgiusti@t530 work (master)]$ qpid-stat -q
Queues
queue dur autoDel excl msg msgIn msgOut bytes bytesIn bytesOut cons bind
=================================================================================================================================
387992b3-6659-4075-ab30-698bd909ada7:0.0 Y Y 0 0 0 0 0 0 1 2
my-topic 0 2 2 0 683 683 2 2
my-topic.my-other-server 0 1 1 0 392 392 1 2
my-topic.my-server-name 0 0 0 0 0 0 1 2
my-topic_fanout_2a86fac82e014295b4648bea84f5351f Y Y 0 1 1 0 392 392 1 2
my-topic_fanout_790d07a871094e9fa929da2d2ecf3888 Y Y 0 1 1 0 392 392 1 2
reply_905ca1ad8a8447fdb13ebf95f3b42fa3 0 2 2 0 362 362 0 2
reply_9dc86f831d104e96ae226677ca360897 0 2 2 0 362 362 0 2
reply_c31daeafc83a4f6eb83adb14d190494f 0 4 4 0 724 724 0 2
(pyenv)[kgiusti@t530 work (master)]$ qpid-stat -e
Exchanges
exchange type dur bind msgIn msgOut msgDrop byteIn byteOut byteDrop
===============================================================================================================
direct 9 8 8 0 1.45k 1.45k 0
None direct 0 2 0 2 268 0 268
amq.direct direct Y 0 0 0 0 0 0 0
amq.fanout fanout Y 0 0 0 0 0 0 0
amq.match headers Y 0 0 0 0 0 0 0
amq.topic topic Y 0 0 0 0 0 0 0
my-topic_fanout fanout 2 1 2 0 392 784 0
openstack topic Y 3 3 3 0 1.07k 1.07k 0
qmf.default.direct direct 0 0 0 0 0 0 0
qmf.default.topic topic 1 101 1 100 134k 14.2k 120k
qpid.management topic 0 0 0 0 0 0 0
reply_905ca1ad8a8447fdb13ebf95f3b42fa3 direct Y 1 0 0 0 0 0 0
reply_9dc86f831d104e96ae226677ca360897 direct Y 1 0 0 0 0 0 0
reply_c31daeafc83a4f6eb83adb14d190494f direct Y 1 0 0 0 0 0 0
(pyenv)[kgiusti@t530 work (master)]$ qpid-stat -u
Subscriptions
subscr queue conn procName procId browse acked excl creditMode delivered sessUnacked
======================================================================================================================================================================
0 051f7a41-313d-447c-bbbb-56676b9fa0ac:0.0 qpid.[::1]:5672-[::1]:37153 qpid-stat 26548 CREDIT 0 0
0 my-topic qpid.[::1]:5672-[::1]:37140 my-server.py 26153 CREDIT 1 0
1 my-topic.my-other-server qpid.[::1]:5672-[::1]:37140 my-server.py 26153 CREDIT 1 0
2 my-topic_fanout_2a86fac82e014295b4648bea84f5351f qpid.[::1]:5672-[::1]:37140 my-server.py 26153 CREDIT 1 0
0 my-topic qpid.[::1]:5672-[::1]:37139 my-server.py 26073 CREDIT 1 0
1 my-topic.my-server-name qpid.[::1]:5672-[::1]:37139 my-server.py 26073 CREDIT 0 0
2 my-topic_fanout_790d07a871094e9fa929da2d2ecf3888 qpid.[::1]:5672-[::1]:37139 my-server.py 26073 CREDIT 1 0
## private queue, no exchange (queue is _shared_)
./drain -f "testq; {create: always, node: { type: queue, durable: True, x-declare: {auto-delete: True }}}"
./drain -f "testq; {create: always, node: { type: queue, durable: True, x-declare: {auto-delete: True }}}"
## all below - copy of msg is sent to each drain!!! ###
## shared topic, private queue, copy to each. Topic exchange persists, queues delete on close
./drain -f "testq; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True }}}" &
./drain -f "testq; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True }}}" &
## shared direct - same behavior as above
./drain -f "testq2; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}}" &
./drain -f "testq2; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}}" &
## ditto, but with named queues (which auto delete)
./drain -f "testq2; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag1}}"
./drain -f "testq2; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag2}}"
## this time with named "bindings" routed by subject
./drain -f "testq3/testme; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag3}}" &
./drain -f "testq3/testme; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag4}}" &
#### !!!THIS!!!! will create two consumers sharing the same queue
./drain -f "testq3/testme; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag4, x-declare: {exclusive: False}}}" &
./drain -f "testq3/testme; {create: always, node: { type: topic, durable: True, x-declare: {auto-delete: True, type: direct }}, link: {name:foobag4, x-declare: {exclusive: False}}}" &
NOTE:
x-declare: {auto-delete: XXX} ONLY APPLIES TO THE 'link' portion - can be left out of the 'node' segment
./drain -f "testq4/testme; {create: always, node: { type: topic, durable: True, x-declare: {type: direct }}, link: {name:foobag4, x-declare: {exclusive: False, auto-delete: false}}}"