Running Artemis 2.28.0 in HA cluster active:stanby pair under Kubernetes. 
System will run for a period of time and then we will start seeing these 
messages in the log. What does this mean?



2023-10-04 20:50:53,098 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=110], 
variableHeader=MqttMessageIdAndPropertiesVariableHeader[messageId=1, 
properties=io.netty.handler.codec.mqtt.MqttProperties@79b1f918<mailto:properties=io.netty.handler.codec.mqtt.MqttProperties@79b1f918>],
 
payload=MqttSubscribePayload[MqttTopicSubscription[topicFilter=trusted/+/nfs/dropped_messages/myhost1:22,
 option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, 
retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]], 
MqttTopicSubscription[topicFilter=trusted/+/nfs/server/state, 
option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, 
retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]], 
MqttTopicSubscription[topicFilter=trusted/+/nfs/client/state, 
option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, 
retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]]]]

java.util.NoSuchElementException: null

        at 
org.apache.activemq.artemis.utils.collections.LinkedListImpl$Iterator.next(LinkedListImpl.java:581)
 ~[artemis-commons-2.28.0.jar:?]

        at 
org.apache.activemq.artemis.utils.collections.PriorityLinkedListImpl$PriorityLinkedListIterator.next(PriorityLinkedListImpl.java:287)
 ~[artemis-commons-2.28.0.jar:?]

        at 
org.apache.activemq.artemis.core.server.impl.QueueImpl$SynchronizedIterator.next(QueueImpl.java:4367)
 ~[artemis-server-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.server.impl.QueueImpl$SynchronizedIterator.next(QueueImpl.java:4335)
 ~[artemis-server-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.protocol.mqtt.MQTTRetainMessageManager.addRetainedMessagesToQueue(MQTTRetainMessageManager.java:79)
 ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.addSubscription(MQTTSubscriptionManager.java:127)
 ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.addSubscriptions(MQTTSubscriptionManager.java:323)
 ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolHandler.handleSubscribe(MQTTProtocolHandler.java:377)
 ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0]

        at 
org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolHandler.act(MQTTProtocolHandler.java:176)
 ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0]

        at org.apache.activemq.artemis.utils.actors.Actor.doTask(Actor.java:32) 
~[artemis-commons-2.28.0.jar:?]

        at 
org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
 ~[artemis-commons-2.28.0.jar:?]

        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) 
~[?:?]

        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 
~[?:?]

        at 
org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
 ~[artemis-commons-2.28.0.jar:?]

Thanks,
Paul Shields

Reply via email to