Skip to content

Commit e0455f0

Browse files
authored
service bus: Fix ServiceBusReceiveLinkProcessorTest unit test - addCredit api invocation count error (Azure#20073)
* Service bus Fix live test failure . closing processor
1 parent a6ea562 commit e0455f0

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

sdk/servicebus/azure-messaging-servicebus/src/test/java/com/azure/messaging/servicebus/implementation/ServiceBusReceiveLinkProcessorTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,9 @@ void createNewLink() {
140140
assertFalse(processor.hasError());
141141
assertNull(processor.getError());
142142

143+
// dispose the processor
144+
processor.dispose();
145+
143146
// Add credit for each time 'onNext' is called, plus once when publisher is subscribed.
144147
verify(link1, times(3)).addCredits(eq(PREFETCH - 1));
145148
}
@@ -571,6 +574,9 @@ void receivesFromFirstLink() {
571574
assertFalse(processor.hasError());
572575
assertNull(processor.getError());
573576

577+
// dispose the processor
578+
processor.dispose();
579+
574580
// Add credit for each time 'onNext' is called, plus once when publisher is subscribed.
575581
verify(link1, times(3)).addCredits(eq(PREFETCH));
576582
verify(link1).setEmptyCreditListener(creditSupplierCaptor.capture()); // Add 0.

0 commit comments

Comments
 (0)