[
https://issues.apache.org/jira/browse/ARTEMIS-2875?focusedWorklogId=479504&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-479504
]
ASF GitHub Bot logged work on ARTEMIS-2875:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 07/Sep/20 06:53
Start Date: 07/Sep/20 06:53
Worklog Time Spent: 10m
Work Description: Pretorianer opened a new pull request #3255:
URL: https://github.com/apache/activemq-artemis/pull/3255
While handling a re-establish connection on failover it can happen that the
client can connect to the broker and re-establish a connection, but while
reattaching all sessions to the new connection another connection loss can
happen and there the failover fails without any possibility to recover on its
own.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 479504)
Remaining Estimate: 0h
Time Spent: 10m
> 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
> Priority: Critical
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)
