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.

Sign up for GitHub

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 31 commits into
base: main
Choose a base branch
from

EventHubConsumerClientTest: rewriting the test class to more readable…

ed69925
Select commit
Loading
Failed to load commit list.
Draft

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

EventHubConsumerClientTest: rewriting the test class to more readable…
ed69925
Select commit
Loading
Failed to load commit list.
Azure Pipelines / java - eventhubs - ci succeeded Feb 3, 2025 in 6m 13s

Build #20250202.3 had test failures

0 errors / 3 warnings

Details

Tests

  • Failed: 1 (0.01%)
  • Passed: 8,731 (88.09%)
  • Other: 1,180 (11.90%)
  • Total: 9,912
Code coverage

  • 3187 of 4274 lines covered (74.57%)

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:1123)
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:1123)
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:1123)
	at com.azure.messaging.eventhubs.EventHubConsumerClientTest.receivesMultipleTimes(EventHubConsumerClientTest.java:241)
	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)
View more details on Azure Pipelines