Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[WIP | Draft]: Drop the support for AMQP v1 stack #43735

Draft
wants to merge 39 commits into
base: main
Choose a base branch
from

RequestResponseChannel: removes channel wrapper added for v1-v2 side …

04c1fbf
Select commit
Loading
Failed to load commit list.
Draft

[WIP | Draft]: Drop the support for AMQP v1 stack #43735

RequestResponseChannel: removes channel wrapper added for v1-v2 side …
04c1fbf
Select commit
Loading
Failed to load commit list.
Azure Pipelines / java - eventhubs - ci succeeded Feb 8, 2025 in 6m 0s

Build #20250207.3 had test failures

Details

Tests

  • Failed: 3 (0.03%)
  • Passed: 9,285 (87.02%)
  • Other: 1,382 (12.95%)
  • Total: 10,670
Code coverage

  • 2904 of 3826 lines covered (75.90%)

Annotations

Check failure on line 1 in c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - eventhubs - ci

c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes

amqpReceiveLink.receive();
Wanted 1 time:
-> at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)

Raw output
org.mockito.exceptions.verification.TooManyActualInvocations: 

amqpReceiveLink.receive();
Wanted 1 time:
-> at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)


	at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
	at com.azure.messaging.eventhubs.EventHubConsumerClientTest.receivesMultipleTimes(EventHubConsumerClientTest.java:243)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)

Check failure on line 1 in c.a.m.e.i.i.EventHubsConsumerInstrumentationTests.asyncConsumerSpansHaveLinks

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - eventhubs - ci

c.a.m.e.i.i.EventHubsConsumerInstrumentationTests.asyncConsumerSpansHaveLinks

expected: <true> but was: <false>
Raw output
org.opentest4j.AssertionFailedError: expected: <true> but was: <false>
	at org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
	at org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
	at org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
	at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
	at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:31)
	at org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:183)
	at com.azure.messaging.eventhubs.implementation.instrumentation.EventHubsConsumerInstrumentationTests.asyncConsumerSpansHaveLinks(EventHubsConsumerInstrumentationTests.java:239)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinTask.doJoin(ForkJoinTask.java:389)
	at java.util.concurrent.ForkJoinTask.join(ForkJoinTask.java:719)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinTask.doJoin(ForkJoinTask.java:389)
	at java.util.concurrent.ForkJoinTask.join(ForkJoinTask.java:719)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)

Check failure on line 1 in c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - eventhubs - ci

c.a.m.e.EventHubConsumerClientTest.receivesMultipleTimes

amqpReceiveLink.receive();
Wanted 1 time:
-> at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)

Raw output
org.mockito.exceptions.verification.TooManyActualInvocations: 

amqpReceiveLink.receive();
Wanted 1 time:
-> at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
But was 2 times:
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)
-> at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onParentReady(MessageFlux.java:788)


	at com.azure.messaging.eventhubs.EventHubConsumerAsyncClientTest$MockReceiveLink.verifyReceiveCalled(EventHubConsumerAsyncClientTest.java:1124)
	at com.azure.messaging.eventhubs.EventHubConsumerClientTest.receivesMultipleTimes(EventHubConsumerClientTest.java:243)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)