Markus Meierhofer created ARTEMIS-2875: ------------------------------------------
Summary: Failed to handle reestablish connection failover Key: ARTEMIS-2875 URL: https://issues.apache.org/jira/browse/ARTEMIS-2875 Project: ActiveMQ Artemis Issue Type: Bug Components: Broker Affects Versions: 2.14.0 Reporter: Markus Meierhofer While trying to reproduce a different issue in the latest stable version we encountered a client re-connection issue which we could not recover from although all broker settings are configured so that the client tries forever to reconnect (reconnectAttempts set to -1). How to reproduce: * establish connection between client and broker * drop tcp packets for more than TTL so that server closes connection * allow tcp packets so that the client tries to reconnect to broker * drop tcp packets after the new connection is established but before all sessions are transferred to the new connection Here is the log of the incident: {code:java} [WARN 2020-08-05 19:46:13,170 l-threads) org.apache.activemq.artemis.core.client]: AMQ212037: Connection failure to fms/10.1.4.205:61616 has been detected: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 [code=CONNECTION_TIMEDOUT] [ERROR 2020-08-05 19:46:13,170 l-threads) n.bridge.impl.service.BasicServiceServer]: JMS Exception sending service call reply! (Request queue: robot_251.robot_command, Reply queue: ActiveMQTemporaryQueue[bcf8651b-98fc-468a-9d7c-5358e20fe020], Request: RobotCommandRequest(info=SlotCommandInfo(super=CommandInfo(source=SYSTEM, id=610362685300429), gotoOptions=GotoOptions(fineposDirection=DEFAULT ec=true), transferOptions=TransferOptions(PRIMARY_SLOT loadUnits=[]), goalName=EMPTY), type=unload_at, timestamp=2020-08-05T17:46:09.168856Z),Reply to send: RobotCommandResponse(id=0, result=INVALID_GOAL)): [ERROR 2020-08-05 19:46:13,170 l-threads) n.bridge.impl.service.BasicServiceServer]: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 javax.jms.JMSException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:457) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:361) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.addressQuery(ActiveMQSessionContext.java:410) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.addressQuery(ClientSessionImpl.java:791) at org.apache.activemq.artemis.jms.client.ActiveMQSession.checkDestination(ActiveMQSession.java:389) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.doSendx(ActiveMQMessageProducer.java:406) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:220) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:207) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.sendResponse(BasicServiceServer.java:122) at com.incubedit.communication.bridge.impl.service.ServiceServer.handleMessage(ServiceServer.java:33) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.onNewMessage(BasicServiceServer.java:111) at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:110) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1030) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:49) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1153) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) Caused by: org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 ... 21 common frames omitted [WARN 2020-08-05 19:46:13,172 l-threads) org.apache.activemq.artemis.jms.client]: AMQ132001: Unhandled exception thrown from onMessage java.lang.RuntimeException: javax.jms.JMSException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 at com.incubedit.communication.bridge.impl.service.BasicServiceServer.sendResponse(BasicServiceServer.java:138) at com.incubedit.communication.bridge.impl.service.ServiceServer.handleMessage(ServiceServer.java:33) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.onNewMessage(BasicServiceServer.java:111) at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:110) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1030) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:49) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1153) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) Caused by: javax.jms.JMSException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:457) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:361) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.addressQuery(ActiveMQSessionContext.java:410) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.addressQuery(ClientSessionImpl.java:791) at org.apache.activemq.artemis.jms.client.ActiveMQSession.checkDestination(ActiveMQSession.java:389) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.doSendx(ActiveMQMessageProducer.java:406) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:220) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:207) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.sendResponse(BasicServiceServer.java:122) ... 12 common frames omitted Caused by: org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 ... 21 common frames omitted [TRACE 2020-08-05 19:46:13,785 heduling-1 .incubedit.os.fsm.CommandStatusPublisher]: Send heartbeat for command id 596834067617602 from source SYSTEM [WARN 2020-08-05 19:46:13,941 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 5.0 seconds [WARN 2020-08-05 19:46:14,941 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 6.0 seconds [WARN 2020-08-05 19:46:15,941 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 7.0 seconds [WARN 2020-08-05 19:46:16,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-3,5,main] has been blocked for 2234 ms, time limit is 2000 [WARN 2020-08-05 19:46:16,020 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 2823 ms, time limit is 2000 [WARN 2020-08-05 19:46:16,020 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-5,5,main] has been blocked for 2589 ms, time limit is 2000 [DEBUG 2020-08-05 19:46:16,117 ROS-1-612 com.incubedit.agent.LogAgentPosition]: Pose: x=8.97 y=3.23 yaw=-89.6 lastTarget=both_put battery=41.8% temp=0.00 wifi=-50.0dBm [WARN 2020-08-05 19:46:16,941 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 8.0 seconds [WARN 2020-08-05 19:46:17,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-3,5,main] has been blocked for 3233 ms, time limit is 2000 [WARN 2020-08-05 19:46:17,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 3822 ms, time limit is 2000 [WARN 2020-08-05 19:46:17,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-5,5,main] has been blocked for 3588 ms, time limit is 2000 [ERROR 2020-08-05 19:46:17,173 l-threads) org.apache.activemq.artemis.jms.client]: AMQ134005: Message Listener failed to recover session org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 68 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:457) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:361) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sessionStop(ActiveMQSessionContext.java:470) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:1121) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:1110) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:1014) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:997) at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:122) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1030) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:49) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1153) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [WARN 2020-08-05 19:46:17,942 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 9.0 seconds [WARN 2020-08-05 19:46:18,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-7,5,main] has been blocked for 2569 ms, time limit is 2000 [TRACE 2020-08-05 19:46:18,785 heduling-1 .incubedit.os.fsm.CommandStatusPublisher]: Send heartbeat for command id 596834067617602 from source SYSTEM [WARN 2020-08-05 19:46:18,942 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 10.0 seconds [WARN 2020-08-05 19:46:19,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-7,5,main] has been blocked for 3569 ms, time limit is 2000 [WARN 2020-08-05 19:46:19,942 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 11.0 seconds [WARN 2020-08-05 19:46:20,020 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 2823 ms, time limit is 2000 [WARN 2020-08-05 19:46:20,942 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 12.0 seconds [WARN 2020-08-05 19:46:21,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-3,5,main] has been blocked for 2233 ms, time limit is 2000 [WARN 2020-08-05 19:46:21,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 3822 ms, time limit is 2000 [WARN 2020-08-05 19:46:21,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-5,5,main] has been blocked for 2583 ms, time limit is 2000 [WARN 2020-08-05 19:46:21,943 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 13.0 seconds [WARN 2020-08-05 19:46:22,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-3,5,main] has been blocked for 3233 ms, time limit is 2000 [WARN 2020-08-05 19:46:22,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-7,5,main] has been blocked for 2569 ms, time limit is 2000 [WARN 2020-08-05 19:46:22,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-5,5,main] has been blocked for 3584 ms, time limit is 2000 [WARN 2020-08-05 19:46:22,943 1-thread-1 agent.control.emergency.EmergencyHandler]: Emergency because emergency status message was not received for 14.0 seconds [WARN 2020-08-05 19:46:23,019 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-7,5,main] has been blocked for 3569 ms, time limit is 2000 [WARN 2020-08-05 19:47:19,026 ad-checker io.vertx.core.impl.BlockedThreadChecker]: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 3705 ms, time limit is 2000 [ERROR 2020-08-05 19:47:19,284 l-threads) org.apache.activemq.artemis.core.client]: AMQ214003: Failed to handle failover org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 30 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:457) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:361) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.recreateSession(ActiveMQSessionContext.java:867) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.handleFailover(ClientSessionImpl.java:1423) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.reconnectSessions(ClientSessionFactoryImpl.java:792) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:635) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:525) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.access$600(ClientSessionFactoryImpl.java:74) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingFailureListener.connectionFailed(ClientSessionFactoryImpl.java:1247) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.callFailureListeners(AbstractRemotingConnection.java:78) at org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.fail(RemotingConnectionImpl.java:220) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.fail(AbstractRemotingConnection.java:221) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.lambda$asyncFail$0(AbstractRemotingConnection.java:228) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)[ERROR 2020-08-05 19:47:19,291 read-13654 munication.bridge.impl.ArtemisBridgeImpl]: JMS exception listener retrieved exception! javax.jms.JMSException: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49] at org.apache.activemq.artemis.jms.client.ActiveMQConnection$JMSFailureListener.connectionFailed(ActiveMQConnection.java:750) at org.apache.activemq.artemis.jms.client.ActiveMQConnection$JMSFailureListener.connectionFailed(ActiveMQConnection.java:771) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.callSessionFailureListeners(ClientSessionFactoryImpl.java:722) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:658) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:525) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.access$600(ClientSessionFactoryImpl.java:74) at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingFailureListener.connectionFailed(ClientSessionFactoryImpl.java:1247) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.callFailureListeners(AbstractRemotingConnection.java:78) at org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.fail(RemotingConnectionImpl.java:220) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.fail(AbstractRemotingConnection.java:221) at org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection.lambda$asyncFail$0(AbstractRemotingConnection.java:228) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) Caused by: org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException: AMQ219014: Timed out after waiting 4,000 ms for response when sending packet 49 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:457) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:361) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.addressQuery(ActiveMQSessionContext.java:410) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.addressQuery(ClientSessionImpl.java:791) at org.apache.activemq.artemis.jms.client.ActiveMQSession.checkDestination(ActiveMQSession.java:389) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.doSendx(ActiveMQMessageProducer.java:406) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:220) at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:207) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.sendResponse(BasicServiceServer.java:122) at com.incubedit.communication.bridge.impl.service.ServiceServer.handleMessage(ServiceServer.java:33) at com.incubedit.communication.bridge.impl.service.BasicServiceServer.onNewMessage(BasicServiceServer.java:111) at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:110) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1030) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:49) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1153) ... 6 common frames omitted[ERROR 2020-08-05 19:47:19,352 p-thread-2 ridge.impl.pubsub.VertexToBridgeConsumer]: JMS exception during handle (Topic: navigation_data, message to send: NavigationData(timestamp=1596649618735, ): [ERROR 2020-08-05 19:47:19,352 p-thread-2 ridge.impl.pubsub.VertexToBridgeConsumer]: Session is closed javax.jms.IllegalStateException: Session is closed at org.apache.activemq.artemis.jms.client.ActiveMQSession.checkClosed(ActiveMQSession.java:1252) at org.apache.activemq.artemis.jms.client.ActiveMQSession.createBytesMessage(ActiveMQSession.java:154) at com.incubedit.communication.bridge.impl.MessageFactoryImpl.createBinaryMessage(MessageFactoryImpl.java:52) at com.incubedit.communication.bridge.impl.MessageFactoryImpl.createMessage(MessageFactoryImpl.java:39) at com.incubedit.communication.bridge.impl.pubsub.VertexToBridgeConsumer.handle(VertexToBridgeConsumer.java:53) at com.incubedit.communication.bridge.impl.pubsub.VertexToBridgeConsumer.handle(VertexToBridgeConsumer.java:20) at io.vertx.core.eventbus.impl.HandlerRegistration.deliver(HandlerRegistration.java:223) at io.vertx.core.eventbus.impl.HandlerRegistration.handle(HandlerRegistration.java:200) at io.vertx.core.eventbus.impl.EventBusImpl.lambda$deliverToHandler$3(EventBusImpl.java:533) at io.vertx.core.impl.ContextImpl.lambda$wrapTask$2(ContextImpl.java:339) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:834) {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)