Reported by 
ewm (1251234643|%O ago)
Using the topic exchange I have setup three programs. Ones that receives messages(Master) from multiple senders and sends replys to them using the queue name and routing key. One that sends messages(sender) to the Master and receives a reply message and one that reads all messages(readAll) binding as "XXX.*". The readAll process is NOT getting the message sent by the Master program.
Here are the messages from the amq_server using -debug_route 1:
2009-08-25 13:30:01: X: create exchange=XXX_Internal type=topic
2009-08-25 13:30:01: X: bind $default$: queue=XXX_Topic.mySystem.myCompany.com_12340
2009-08-25 13:30:01: X: compile $default$: routing_key=XXX_Topic.mySystem.myCompany.com_12340
2009-08-25 13:30:01: X: bind XXX_Internal: queue=XXX_Topic.mySystem.myCompany.com_12340
2009-08-25 13:30:01: X: compile XXX_Internal: topic=XXX.Master
2009-08-25 13:30:01: X: newtopic XXX_Internal: topic=XXX.Master
2009-08-25 13:30:04: X: bind $default$: queue=XXX_Topic.mySystem.myCompany.com_12351
2009-08-25 13:30:04: X: compile $default$: routing_key=XXX_Topic.mySystem.myCompany.com_12351
2009-08-25 13:30:04: X: bind XXX_Internal: queue=XXX_Topic.mySystem.myCompany.com_12351
2009-08-25 13:30:04: X: compile XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:04: X: index XXX_Internal: wildcard=XXX.* routing_key=XXX.Master
2009-08-25 13:30:04: X: publish XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:04: X: route XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:04: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:04: X: hit XXX_Internal: wildcard=XXX.Master
2009-08-25 13:30:04: X: discard queue=XXX_Topic.mySystem.myCompany.com_12351 (direct, no-local, undeliverable)
2009-08-25 13:30:04: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12340 (direct)
2009-08-25 13:30:04: X: publish XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:04: X: route XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:04: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:04: X: hit XXX_Internal: wildcard=XXX.Master
2009-08-25 13:30:04: X: discard queue=XXX_Topic.mySystem.myCompany.com_12351 (direct, no-local, undeliverable)
2009-08-25 13:30:04: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12340 (direct)
2009-08-25 13:30:04: X: publish XXX_Internal: routing_key=XXX.ReadMsgs_mySystem_12351
2009-08-25 13:30:04: X: newtopic XXX_Internal: topic=XXX.ReadMsgs_mySystem_12351
2009-08-25 13:30:04: X: index XXX_Internal: routing_key=XXX.ReadMsgs_mySystem_12351 wildcard=XXX.*
2009-08-25 13:30:04: X: route XXX_Internal: routing_key=XXX.ReadMsgs_mySystem_12351
2009-08-25 13:30:04: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:04: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12351 (direct)
2009-08-25 13:30:08: X: bind $default$: queue=XXX_Topic.mySystem.myCompany.com_12357
2009-08-25 13:30:08: X: compile $default$: routing_key=XXX_Topic.mySystem.myCompany.com_12357
2009-08-25 13:30:08: X: bind XXX_Internal: queue=XXX_Topic.mySystem.myCompany.com_12357
2009-08-25 13:30:08: X: compile XXX_Internal: topic=XXX.SendMsg_mySystem_12357
2009-08-25 13:30:08: X: newtopic XXX_Internal: topic=XXX.SendMsg_mySystem_12357
2009-08-25 13:30:08: X: publish XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: route XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.Master
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12351 (direct)
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12340 (direct)
2009-08-25 13:30:08: X: publish XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: route XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.Master
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12351 (direct)
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12340 (direct)
2009-08-25 13:30:08: X: publish XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: route XXX_Internal: routing_key=XXX.Master
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.*
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.Master
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12351 (direct)
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12340 (direct)
2009-08-25 13:30:08: X: publish XXX_Internal: routing_key=XXX.SendMsg_mySystem_12357
2009-08-25 13:30:08: X: route XXX_Internal: routing_key=XXX.SendMsg_mySystem_12357
2009-08-25 13:30:08: X: hit XXX_Internal: wildcard=XXX.SendMsg_mySystem_12357
2009-08-25 13:30:08: X: deliver queue=XXX_Topic.mySystem.myCompany.com_12357 (direct)
Attachments:
No files attached to this page.
Comments
Who's following this issue?
Submitted by ewm
Use one of these tags to say what kind of issue it is:
- issue - a fault in the software or the packaging or the documentation.
- change - a change or feature request.
Use one of these tags to say what state the issue is in:
- open - a new, open issue.
- closed - issue has been closed.
- rejected - the issue has been rejected.
Use one of these tags to say how urgent the issue is:
- fatal - the issue is stopping all work.
- urgent - it's urgent.
All open
87 - Zyre returns incomplete XML (26 Apr 2010 08:15) [open]
86 - SFL 'random(num)' macro is wrong in sfl.h (31 Mar 2010 09:23) [open]
85 - Zyre does not start on Solaris (23 Mar 2010 01:29) [open]
84 - OpenAMQ JMS - AMQTopic constructor use HEADER name and class instead of TOPIC (28 Jan 2010 17:04) [open]
83 - WireAPI: How to 'override' signal handlers? (14 Jan 2010 17:33) [open]
82 - Opf Classes Cannot Accept Default Values With Characte (06 Jan 2010 09:34) [open]
81 - AMQP Topic Exhange Routing (29 Dec 2009 00:21) [open]
80 - OpenAMQ reports malformed frame on 0-9-1 queue.unbind (20 Nov 2009 12:33) [open]
79 - AMQ Server crashing if subscribe topic is set as #.# (30 Oct 2009 06:11) [open]
78 - Error while publishing the messages faster (30 Oct 2009 05:57) [open]
77 - Tuning for latency (28 Oct 2009 16:47) [open]
76 - New user forum (28 Oct 2009 11:29) [change open]
74 - Simulaneous connect/disconnect from multiple threads crashes (03 Sep 2009 15:32) [open]
73 - Topic Exchange not sending a message to XXX.* (25 Aug 2009 21:10) [open]
72 - amq_content_basic_new() causes seg fault if not connected to broker (12 Aug 2009 23:50) [open]
71 - zyre bugs (06 Aug 2009 09:33) [open]
69 - OpenAMQ and Zyre (15 Jul 2009 11:27) [open]
68 - Change names of max and min source code macros (10 Jul 2009 16:52) [open]
67 - Server crash when multiple consumers ack on shared queue (26 Jun 2009 11:35) [open]
63 - Broker Crashing (14 May 2009 20:17) [open]
Most recent
88 - amq_console_agent crashes (28 Aug 2010 08:46) [closed]
87 - Zyre returns incomplete XML (26 Apr 2010 08:15) [open]
86 - SFL 'random(num)' macro is wrong in sfl.h (31 Mar 2010 09:23) [open]
85 - Zyre does not start on Solaris (23 Mar 2010 01:29) [open]
84 - OpenAMQ JMS - AMQTopic constructor use HEADER name and class instead of TOPIC (28 Jan 2010 17:04) [open]
83 - WireAPI: How to 'override' signal handlers? (14 Jan 2010 17:33) [open]
82 - Opf Classes Cannot Accept Default Values With Characte (06 Jan 2010 09:34) [open]
81 - AMQP Topic Exhange Routing (29 Dec 2009 00:21) [open]
80 - OpenAMQ reports malformed frame on 0-9-1 queue.unbind (20 Nov 2009 12:33) [open]
79 - AMQ Server crashing if subscribe topic is set as #.# (30 Oct 2009 06:11) [open]
try using xxx instead of XXX
I changed to all lower case and still not getting the hit from the master to the readAll process binding to *.# xxx.* & *.*
I do get the message(s) going to the master process from any other process just not FROM the master process.
I sent the same message out twice:
1)XXX.MyProcessNAme_mySystem_791
2)XXX.ReadAll
The wildcard only found the second match
2009-09-03 16:05:11: X: publish XXX_internalT: routing_key=XXX.MyProcessName_mySystem_791
2009-09-03 16:05:11: X: route XXX_internalT: routing_key=XXX.MyProcessName_mySystem_791
2009-09-03 16:05:11: X: hit XXX_internalT: wildcard=XXX.MyProcessName_mySystem_791
2009-09-03 16:05:11: X: deliver queue=XXX_topic.mySystem.myCompany.com_791
2009-09-03 16:05:11: X: publish XXX_internalT: routing_key=XXX.ReadAll
2009-09-03 16:05:11: X: route XXX_internalT: routing_key=XXX.ReadAll
2009-09-03 16:05:11: X: hit XXX_internalT: wildcard=XXX.*
2009-09-03 16:05:11: X: deliver queue=XXX_topic.mySystem.myCompany.com_780