[jira] [Closed] (ARTEMIS-4044) AMQ219010: Connection is destroyed with embedded artemis in tests

["Stephen Baker (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/ARTEMIS-4044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephen Baker closed ARTEMIS-4044.
----------------------------------
    Resolution: Invalid

> AMQ219010: Connection is destroyed with embedded artemis in tests
> -----------------------------------------------------------------
>
>                 Key: ARTEMIS-4044
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-4044
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>         Environment: MacOS 12.6
> Corretto JDK 11
> Spring Boot 2.7.4
> artemis.version set to 2.26.0
>            Reporter: Stephen Baker
>            Priority: Minor
>         Attachments: failure.log, success.log, success_2_19_1.log
>
>
> I have a unit test for verifying a listener routine I wrote in the event of an Artemis failure.
> With artemis-server 2.25.0 and 2.26.0 it is periodically failing to obtain a connection AFTER the server has finished starting. 
> {code:java}
> @Test
> void receiveBatchesTest_resilientToJmsFailure() throws Exception {
>     var receiveCount = new AtomicInteger(0);
>     BatchingJmsListenerDefinition<String> listener = BatchingJmsListenerDefinition.builder(String.class)
>             .concurrency(1)
>             .maxBatchSize(10)
>             .destination("TestQueue")
>             .jmsTemplate(jmsTemplate)
>             .target(s -> receiveCount.addAndGet(s.size()))
>             .receiveTimeout(Duration.ofSeconds(1))
>             .errorPauseTime(Duration.ofMillis(1))
>             .build();
>     embeddedActiveMQ.stop();
>     registry.registerListener(listener, true);
>     await().atLeast(Duration.ofMillis(1000));
>     embeddedActiveMQ.start();
>     jmsTemplate.convertAndSend("TestQueue", "message1");
>     jmsTemplate.convertAndSend("TestQueue", "message2");
>     await().atMost(5, TimeUnit.SECONDS).until(() -> receiveCount.get() == 2);
> }{code}
> * [^failure.log]
> * [^success.log]
> * [^success_2_19_1.log]
> When {{registerListener}} is called we expect a connection failure and on 2.19.1 we get one there "AMQ219007: Cannot connect to server(s). Tried with all available servers." but it should catch and try again until the server comes up, and then when we write to the queue after the server is up we definitely expect the connection to work, but as can be seen in the [^failure.log] we are getting:
> {noformat}
> ActiveMQNotConnectedException[errorType=NOT_CONNECTED message=AMQ219010: Connection is destroyed{noformat} 
> Line 117 is the first {{jmsTemplate.convertAndSend}}.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)