Hello! I've been using Artemis for anycast queues for a couple of years now. I've now come up against a problem that requires a multicast queue, so I've been trying to put together some simple code that would let me test a single-writer, multiple-consumer multicast address.
Unfortunately, I can't seem to get the consumers to receive any messages. Here's the code I'm using: https://github.com/io7m/activemq-20210603/tree/master/src/main/java/com/io7m/mq The writer writes messages to the "info.arc7.unrestricted.base" address. I've tried setting the routing type to MULTICAST on individual addresses, but this made no difference. The reader creates an automatically-deleted queue called "info.arc7.unrestricted.base.q" using "info.arc7.unrestricted.base" as the address. It then goes into a loop performing a blocking receive. It never receives anything. In the server logs, I see messages such as: 2021-06-03 10:36:39,793 INFO [org.apache.activemq.audit.message] AMQ601500: User peppermint(amq)@10.2.4.1:50748 is sending a core message with Context: RoutingContextImpl(Address=info.arc7.unrestricted.base, routingType=MULTICAST, PreviousAddress=info.arc7.unrestricted.base previousRoute:MULTICAST, reusable=true, version=-2147483526) In the web interface, I see that the "un routed message count" for the "info.arc7.unrestricted.base" address is steadily rising, and the "info.arc7.unrestricted.base.q" queue consistently has no messages in it. The web view shows both address and queue as having a routing type of MULTICAST. Is there something else I'm supposed to do? -- Mark Raynsford | https://www.io7m.com
pgpdLueR1HRrb.pgp
Description: OpenPGP digital signature
