Hi, Running Artemis 2.28.0 in HA cluster active:stanby pair under Kubernetes. Every so often we will see the Error removing subscription message in the active broker log. It is usually proceeded by the AMQ834002: Error processing control packet message. What is causing this error?
Thanks, Paul 2023-10-04 22:07:07,081 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/+/dvs/dropped_messages/x1000c3s6b1n1:60, option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]], MqttTopicSubscription[topicFilter=trusted/+/dvs/server/state, option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]], MqttTopicSubscription[topicFilter=trusted/+/dvs/client/state, option=SubscriptionOption[qos=AT_MOST_ONCE, noLocal=false, retainAsPublished=false, retainHandling=SEND_AT_SUBSCRIBE]]]] org.apache.activemq.artemis.api.core.ActiveMQIllegalStateException: AMQ229232: Cannot create consumer on x1000c3s6b1n1:60.trusted/+/dvs/dropped_messages/x1000c3s6b1n1:60. Session is closed. at org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.createConsumer(ServerSessionImpl.java:574) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.createConsumer(ServerSessionImpl.java:525) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.createConsumerForSubscriptionQueue(MQTTSubscriptionManager.java:231) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.addSubscription(MQTTSubscriptionManager.java:116) ~[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:?] 2023-10-04 22:07:07,814 ERROR [org.apache.activemq.artemis.core.protocol.mqtt] AMQ834000: Error removing subscription. java.lang.IllegalStateException: Cannot find binding x1000c3s6b0n1:34.trusted/+/dvs/client/state at org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager.removeBindingInternal(SimpleAddressManager.java:221) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.WildcardAddressManager.lambda$removeBinding$2(WildcardAddressManager.java:129) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.AddressPartNode.visitValues(AddressPartNode.java:276) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.AddressPartNode.visitNonWildcard(AddressPartNode.java:219) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.AddressPartNode.visitNonWildcard(AddressPartNode.java:196) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.AddressMap.visitMatching(AddressMap.java:64) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.WildcardAddressManager.removeBinding(WildcardAddressManager.java:129) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl.removeBinding(PostOfficeImpl.java:969) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.server.impl.QueueImpl.deleteQueue(QueueImpl.java:2354) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.destroyQueue(ActiveMQServerImpl.java:2473) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.destroyQueue(ActiveMQServerImpl.java:2422) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.deleteQueue(ServerSessionImpl.java:1186) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.removeSubscription(MQTTSubscriptionManager.java:283) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSubscriptionManager.clean(MQTTSubscriptionManager.java:362) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSession.clean(MQTTSession.java:226) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTSession.stop(MQTTSession.java:145) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTConnectionManager.disconnect(MQTTConnectionManager.java:185) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTFailureListener.connectionFailed(MQTTFailureListener.java:41) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTFailureListener.connectionFailed(MQTTFailureListener.java:36) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.protocol.mqtt.MQTTConnection.fail(MQTTConnection.java:52) ~[artemis-mqtt-protocol-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$FailureCheckAndFlushThread$2.run(RemotingServiceImpl.java:781) ~[artemis-server-2.28.0.jar:2.28.0] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:57) ~[artemis-commons-2.28.0.jar:?] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.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:?]
