[WIP | Draft]: Drop the support for AMQP v1 stack #43735
Draft
Azure Pipelines / java - core - ci
succeeded
Feb 8, 2025 in 54m 56s
Build #20250207.4 had test failures
Details
- Failed: 2 (0.00%)
- Passed: 309,113 (98.77%)
- Other: 3,833 (1.22%)
- Total: 312,948
- 17668 of 25454 lines covered (69.41%)
Annotations
Check failure on line 1 in c.a.c.t.TestProxyTests.testResetTestProxyData
azure-pipelines / java - core - ci
c.a.c.t.TestProxyTests.testResetTestProxyData
reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response
Raw output
java.io.UncheckedIOException: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response
at [email protected]/com.azure.core.http.netty.NettyAsyncHttpClient.sendSync(NettyAsyncHttpClient.java:201)
at [email protected]/com.azure.core.test.policy.TestProxyRecordPolicy.stopRecording(TestProxyRecordPolicy.java:116)
at [email protected]/com.azure.core.test.InterceptorManager.close(InterceptorManager.java:355)
at [email protected]/com.azure.core.test.TestBase.teardownTest(TestBase.java:202)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
Caused by: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response
Check failure on line 1 in c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes
azure-pipelines / java - core - ci
c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes
amqpReceiveLink.receive();
Wanted 1 time:
-> at [email protected]/com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at [email protected]/com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at [email protected]/com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
Raw output
org.mockito.exceptions.verification.TooManyActualInvocations:
amqpReceiveLink.receive();
Wanted 1 time:
-> at [email protected]/com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at [email protected]/com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at [email protected]/com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
at [email protected]/com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
at [email protected]/com.azure.messaging.eventhubs.EventHubConsumerClientTest.receivesMultipleTimes(EventHubConsumerClientTest.java:243)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.tryRemoveAndExec(ForkJoinPool.java:1351)
at java.base/java.util.concurrent.ForkJoinTask.awaitDone(ForkJoinTask.java:422)
at java.base/java.util.concurrent.ForkJoinTask.join(ForkJoinTask.java:651)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
Loading