Skip to content

Commit 5baa2ef

Browse files
committed
Merge branch 'nats-backend' of github.com:/sonus21/rqueue into nats-backend
2 parents 30a04a4 + db70a4d commit 5baa2ef

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerUnitTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,8 @@ void enqueueWithPriority_appendsPrioritySuffixToSubject() throws Exception {
8888
queueNamed("orders"),
8989
"high",
9090
RqueueMessage.builder().id("m1").message("hi").build());
91-
verify(f.js, times(1)).publish(eq("rqueue.js.orders.high"), any(Headers.class), any(byte[].class));
91+
verify(f.js, times(1))
92+
.publish(eq("rqueue.js.orders.high"), any(Headers.class), any(byte[].class));
9293
}
9394

9495
@Test
@@ -169,7 +170,8 @@ void enqueueReactive_completesWhenPublishFutureCompletes() {
169170
StepVerifier.create(f.broker.enqueueReactive(
170171
queueNamed("orders"), RqueueMessage.builder().id("m1").message("hi").build()))
171172
.verifyComplete();
172-
verify(f.js, times(1)).publishAsync(eq("rqueue.js.orders"), any(Headers.class), any(byte[].class));
173+
verify(f.js, times(1))
174+
.publishAsync(eq("rqueue.js.orders"), any(Headers.class), any(byte[].class));
173175
}
174176

175177
@Test

0 commit comments

Comments
 (0)