You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Justin Bertram (Jira)" <ji...@apache.org> on 2022/09/14 17:56:00 UTC

[jira] [Commented] (ARTEMIS-3979) Change in behavior when dynamically creating queue based on FQQN for Openwire clients

    [ https://issues.apache.org/jira/browse/ARTEMIS-3979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604881#comment-17604881 ] 

Justin Bertram commented on ARTEMIS-3979:
-----------------------------------------

You could narrow down the problem by manually configuring the queue in your {{broker.xml}}, e.g.:
{code:xml}
      <addresses>
         ...
         <address name="MyTopic">
            <multicast>
               <queue name="MQ1" />
            </multicast>
         </address>
      </addresses>{code}
You might also try disabling auto-delete, e.g.:
{code:xml}
      <address-settings>
         ...
         <address-setting match="#">
            ...
            <auto-delete-queues>false</auto-delete-queues>
            <auto-delete-addresses>false</auto-delete-addresses>
            ...
         </address-setting>
      </address-settings>
{code}
Also, when you run into this issue it would be good to know the {{consumerCount}}, {{messageCount}}, and {{deliveringCount}} of the {{MQ1}} queue.

You may also consider migrating to another client since CMS really isn't maintained any longer.

> Change in behavior when dynamically creating queue based on FQQN for Openwire clients
> -------------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-3979
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-3979
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 2.19.1, 2.24.0
>            Reporter: David Whitney
>            Priority: Major
>         Attachments: broker.xml
>
>
> When using Apache Artemis 2.18.0, I can successfully create a consumer queue using a FQQN (e.g., MyTopic::MQ1) and receive messages from it.
> The consumer performs this:
> {code:java}
> ...
> cms::Destination* dest = session->createQueue(fqqn_topic);
> cms::MessageConsumer* consumer = session.createConsumer(dest);
> ...
> TopicListener* listener = new TopicListener(...);   // a subclass of cms::MessageListener
> consumer->setMessageListener(listener);
> {code}
> My test application creates two consumers subscribed using an FQQN topic, and a single producer that issues 10 messages. I expect each consumer to receive 5 messages each, in a 'ping-pong' manner.
> The test works flawlessly with Artemis 2.18.0, however if I upgrade to later versions, the test sometimes runs successfully, and at other times, the consumer does not receive any messages, thus resulting in a failed test.
> I cannot ascertain if this is an issue with the creation/usage of a dynamically created queue, or perhaps something to do with the delivery of messages to the MessageListener.
> It is quite obvious that something has changed between Artemis 2.18.0 and 2.19.1. Hopefully this issue can be fixed, or perhaps a guidance can be offered to indicate whether I need to tweak my broker's configuration file (which I have attached).



--
This message was sent by Atlassian Jira
(v8.20.10#820010)