You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Lakatos Gyula (Jira)" <ji...@apache.org> on 2021/11/22 20:03:00 UTC
[jira] [Updated] (ARTEMIS-3588) AMQ219060 - Large Message Transmission interrupted error stops the application even when reconnect is set to infinite
[ https://issues.apache.org/jira/browse/ARTEMIS-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lakatos Gyula updated ARTEMIS-3588:
-----------------------------------
Description:
I get the following error occasionally in my application:
{code:java}
2021-11-20 00:27:32.337 INFO 20184 --- [oundedElastic-1] c.g.l.v.service.VaultDocumentManager : Archiving document with id: 6ae3ed96-ecaa-43e2-84a5-5b8371e93765.
2021-11-20 00:27:33.014 ERROR 20184 --- [oundedElastic-1] reactor.core.publisher.Operators : Operator called default onErrorDropped
reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
Caused by: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:93) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:17) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:11) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.lambda$readMessage$3(ArtemisQueueManipulator.java:147) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.consumer.ClientConsumerExecutor.invokeConsumer(ClientConsumerExecutor.java:26) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.readMessage(ArtemisQueueManipulator.java:139) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:22) ~[classes!/:1.4.0]
at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:13) ~[classes!/:1.4.0]
at reactor.core.publisher.FluxGenerate.lambda$new$1(FluxGenerate.java:57) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxGenerate$GenerateSubscription.slowPath(FluxGenerate.java:265) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxGenerate$GenerateSubscription.request(FluxGenerate.java:207) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:447) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.4.10.jar!/:3.4.10]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]
Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.checkException(LargeMessageControllerImpl.java:334) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.waitCompletion(LargeMessageControllerImpl.java:315) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.saveBuffer(LargeMessageControllerImpl.java:275) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.checkBuffer(ClientLargeMessageImpl.java:159) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:91) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
... 19 common frames omitted
Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.cancel(LargeMessageControllerImpl.java:207) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.resetLargeMessageController(ClientConsumerImpl.java:755) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.clearAtFailover(ClientConsumerImpl.java:528) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.handleFailover(ClientSessionImpl.java:1412) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.reconnectSessions(ClientSessionFactoryImpl.java:840) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:664) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:542) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:535) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.access$100(ClientSessionFactoryImpl.java:75) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$1.run(ClientSessionFactoryImpl.java:398) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) ~[artemis-commons-2.18.0.jar!/:2.18.0] {code}
I have a hard time figuring out why this happens. The internet doesn't have any results when I search for it in Google.
Also, I have {{org.apache.activemq.artemis.api.core.client.ServerLocator#setReconnectAttempts}} set to {{-1}} and I would expect Artemis to reconnect to the server in the case of a client error.
was:
I get the following error occasionally in my application:
{code:java}
2021-11-20 00:27:32.337 INFO 20184 --- [oundedElastic-1] c.g.l.v.service.VaultDocumentManager : Archiving document with id: 6ae3ed96-ecaa-43e2-84a5-5b8371e93765.
2021-11-20 00:27:33.014 ERROR 20184 --- [oundedElastic-1] reactor.core.publisher.Operators : Operator called default onErrorDropped
reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
Caused by: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:93) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:17) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:11) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.lambda$readMessage$3(ArtemisQueueManipulator.java:147) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.consumer.ClientConsumerExecutor.invokeConsumer(ClientConsumerExecutor.java:26) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.readMessage(ArtemisQueueManipulator.java:139) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:22) ~[classes!/:1.4.0]
at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:13) ~[classes!/:1.4.0]
at reactor.core.publisher.FluxGenerate.lambda$new$1(FluxGenerate.java:57) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxGenerate$GenerateSubscription.slowPath(FluxGenerate.java:265) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxGenerate$GenerateSubscription.request(FluxGenerate.java:207) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:447) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.4.10.jar!/:3.4.10]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.4.10.jar!/:3.4.10]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]
Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.checkException(LargeMessageControllerImpl.java:334) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.waitCompletion(LargeMessageControllerImpl.java:315) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.saveBuffer(LargeMessageControllerImpl.java:275) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.checkBuffer(ClientLargeMessageImpl.java:159) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:91) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
... 19 common frames omitted
Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.cancel(LargeMessageControllerImpl.java:207) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.resetLargeMessageController(ClientConsumerImpl.java:755) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.clearAtFailover(ClientConsumerImpl.java:528) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.handleFailover(ClientSessionImpl.java:1412) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.reconnectSessions(ClientSessionFactoryImpl.java:840) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:664) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:542) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:535) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.access$100(ClientSessionFactoryImpl.java:75) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$1.run(ClientSessionFactoryImpl.java:398) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) ~[artemis-commons-2.18.0.jar!/:2.18.0]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) ~[artemis-commons-2.18.0.jar!/:2.18.0] {code}
I have a hard time figuring out why this happens. The internet doesn't have any results when I search for it in Google.
Also, I have {{org.apache.activemq.artemis.api.core.client.ServerLocator#setReconnectAttempts}} set to {{-1}} and I would expect Artemis to reconnect to the server in the case of a client error.
> AMQ219060 - Large Message Transmission interrupted error stops the application even when reconnect is set to infinite
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: ARTEMIS-3588
> URL: https://issues.apache.org/jira/browse/ARTEMIS-3588
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Environment: Artemis 2.18.0
> Ubuntu 20.10
> Both the server and the client running on local site addresses (ie 192.168.0.*).
> Reporter: Lakatos Gyula
> Priority: Major
>
> I get the following error occasionally in my application:
> {code:java}
> 2021-11-20 00:27:32.337 INFO 20184 --- [oundedElastic-1] c.g.l.v.service.VaultDocumentManager : Archiving document with id: 6ae3ed96-ecaa-43e2-84a5-5b8371e93765.
> 2021-11-20 00:27:33.014 ERROR 20184 --- [oundedElastic-1] reactor.core.publisher.Operators : Operator called default onErrorDropped
> reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
> Caused by: java.lang.RuntimeException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
> at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:93) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:17) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
> at com.github.loa.queue.artemis.service.consumer.deserializer.DocumentArchivingMessageDeserializer.deserialize(DocumentArchivingMessageDeserializer.java:11) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
> at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.lambda$readMessage$3(ArtemisQueueManipulator.java:147) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
> at com.github.loa.queue.artemis.service.consumer.ClientConsumerExecutor.invokeConsumer(ClientConsumerExecutor.java:26) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
> at com.github.loa.queue.artemis.service.ArtemisQueueManipulator.readMessage(ArtemisQueueManipulator.java:139) ~[loa-queue-artemis-service-1.4.0.jar!/:na]
> at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:22) ~[classes!/:1.4.0]
> at com.github.loa.vault.service.listener.VaultQueueConsumer.accept(VaultQueueConsumer.java:13) ~[classes!/:1.4.0]
> at reactor.core.publisher.FluxGenerate.lambda$new$1(FluxGenerate.java:57) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.publisher.FluxGenerate$GenerateSubscription.slowPath(FluxGenerate.java:265) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.publisher.FluxGenerate$GenerateSubscription.request(FluxGenerate.java:207) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:447) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.4.10.jar!/:3.4.10]
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
> at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
> at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]
> Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
> at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.checkException(LargeMessageControllerImpl.java:334) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.waitCompletion(LargeMessageControllerImpl.java:315) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.saveBuffer(LargeMessageControllerImpl.java:275) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.checkBuffer(ClientLargeMessageImpl.java:159) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientLargeMessageImpl.getBodyBuffer(ClientLargeMessageImpl.java:91) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> ... 19 common frames omitted
> Caused by: org.apache.activemq.artemis.api.core.ActiveMQLargeMessageInterruptedException: AMQ219060: Large Message Transmission interrupted on consumer shutdown.
> at org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl.cancel(LargeMessageControllerImpl.java:207) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.resetLargeMessageController(ClientConsumerImpl.java:755) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.clearAtFailover(ClientConsumerImpl.java:528) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.handleFailover(ClientSessionImpl.java:1412) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.reconnectSessions(ClientSessionFactoryImpl.java:840) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:664) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:542) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:535) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.access$100(ClientSessionFactoryImpl.java:75) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$1.run(ClientSessionFactoryImpl.java:398) ~[artemis-core-client-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) ~[artemis-commons-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) ~[artemis-commons-2.18.0.jar!/:2.18.0]
> at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) ~[artemis-commons-2.18.0.jar!/:2.18.0]
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
> at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) ~[artemis-commons-2.18.0.jar!/:2.18.0] {code}
> I have a hard time figuring out why this happens. The internet doesn't have any results when I search for it in Google.
> Also, I have {{org.apache.activemq.artemis.api.core.client.ServerLocator#setReconnectAttempts}} set to {{-1}} and I would expect Artemis to reconnect to the server in the case of a client error.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)