Hi,
I’m trying to connect an ActiveMQ Artemis topic queue with the
following configurations. Based on my settings, I don’t want to create
dynamic queues when clients establish new connections. However, after
applying this configuration, I’m unable to connect to my topic queue. Could
you please explain why this is happening and guide me to connect the topic
queue without creating the new queue?
*broker.xml* configuration
```
<address-settings>
<!-- if you define auto-create on certain queues, management has
to be auto-create -->
<address-setting match="activemq.management#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<!-- with -1 only the global-max-size is in use for limiting -->
<max-size-bytes>-1</max-size-bytes>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>false</auto-create-queues>
<auto-create-addresses>false</auto-create-addresses>
</address-setting>
<!--default for catch all-->
<address-setting match="#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>false</auto-create-queues>
<auto-create-addresses>false</auto-create-addresses>
<auto-delete-queues>false</auto-delete-queues>
<auto-delete-addresses>false</auto-delete-addresses>
<!-- The size of each page file -->
<page-size-bytes>10M</page-size-bytes>
<!-- When we start applying the address-full-policy, e.g paging
-->
<!-- Both are disabled by default, which means we will use the
global-max-size/global-max-messages -->
<max-size-bytes>-1</max-size-bytes>
<max-size-messages>-1</max-size-messages>
<!-- When we read from paging into queues (memory) -->
<max-read-page-messages>-1</max-read-page-messages>
<max-read-page-bytes>20M</max-read-page-bytes>
<!-- Limit on paging capacity before starting to throw errors
-->
<page-limit-bytes>-1</page-limit-bytes>
<page-limit-messages>-1</page-limit-messages>
</address-setting>
</address-settings>
```
by using this configuration I'm facing queue not found error in
*artemis.log* file
```
2024-04-29 19:15:34,563 ERROR
[org.apache.activemq.artemis.core.protocol.mqtt] AMQ834002: Error
processing control packet:
MqttSubscribeMessage[fixedHeader=MqttFixedHeader[messageType=SUBSCRIBE,
isDup=false, qosLevel=AT_LEAST_ONCE, isRetain=false, remainingLength=35],
variableHeader=MqttMessageIdAndPropertiesVariableHeader[messageId=1,
properties=io.netty.handler.codec.mqtt.MqttProperties@511f28bc],
payload=MqttSubscribePayload[MqttTopicSubscription[topicFilter=ONEEMR/PUSH_NOTIFICATION_TOPIC,
option=SubscriptionOption[qos=AT_LEAST_ONCE, noLocal=false,
retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]]]]
org.apache.activemq.artemis.api.core.ActiveMQNonExistentQueueException:
AMQ229017: Queue ONEEMR.PUSH_NOTIFICATION_TOPIC does not exist
at
org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.createQueueForSubscription(MQTTSubscriptionManager.java:163)
~[artemis-mqtt-protocol-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.addSubscription(MQTTSubscriptionManager.java:108)
~[artemis-mqtt-protocol-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.addSubscriptions(MQTTSubscriptionManager.java:303)
~[artemis-mqtt-protocol-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolHandler.handleSubscribe(MQTTProtocolHandler.java:382)
~[artemis-mqtt-protocol-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolHandler.act(MQTTProtocolHandler.java:177)
~[artemis-mqtt-protocol-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.utils.actors.Actor.doTask(Actor.java:32)
~[artemis-commons-2.33.0.jar:2.33.0]
at
org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
~[artemis-commons-2.33.0.jar:2.33.0]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
[?:?]
at
org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
[artemis-commons-2.33.0.jar:2.33.0]
```
*Thanks in advance😊😊*
On Tue, 30 Apr 2024 at 10:58, Justin Bertram <jbert...@apache.org> wrote:
> From what I can tell you aren't actually subscribed to the ActiveMQ users
> list so you will not receive any replies sent to the list and not directly
> to you (which is how replies are normally sent). Please subscribe [1] to
> the list in order to use it properly. Thanks!
>
> Also, please be aware that screenshots attached to emails are not passed
> to subscribers. If a screenshot is critical to explaining your issue please
> upload it somewhere and provide a link to it. Otherwise simply describe in
> more detail what your problem actually is without referencing screenshots.
>
>
> Justin
>
> [1] https://activemq.apache.org/contact
>
> On Tue, Apr 30, 2024 at 12:14 AM Pushparaj Chinnathambi <
> pushpara...@raster.in> wrote:
>
>> Hi,
>> I’m trying to connect an ActiveMQ Artemis topic queue with the
>> following configurations. Based on my settings, I don’t want to create
>> dynamic queues when clients establish new connections. However, after
>> applying this configuration, I’m unable to connect to my topic queue. Could
>> you please explain why this is happening and guide me on resolving this
>> issue?
>>
>>
>> [image: broker-file-configuration.png]
>> [image: log-file.png][image: queue-settings.png]
>> --
>> *------------------------*
>> *Thanks & Regards,*
>> *Pushparaj Chinnathambi*
>> Team Lead
>> *Raster Images Pvt. Ltd.*
>> Salem 636 004, TN, India
>> E: pushpara...@raster.in
>>
>>
>>
--
*------------------------*
*Thanks & Regards,*
*Pushparaj Chinnathambi*
Team Lead
*Raster Images Pvt. Ltd.*
Salem 636 004, TN, India
E: pushpara...@raster.in
