File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -368,7 +368,7 @@ void findBrokersForStreamShouldReturnReplicasIfThereAreSome() {
368368 }
369369
370370 @ Test
371- void subscribeShouldSubscribeToStreamAndDispatchesMessage_UnsubscribeShouldUnsubscribe () {
371+ void subscribeShouldSubscribeToStreamAndDispatchMessage_UnsubscribeShouldUnsubscribe () {
372372 when (locator .metadata ("stream" )).thenReturn (metadata (null , replicas ()));
373373
374374 when (clientFactory .client (any ())).thenReturn (client );
@@ -410,7 +410,7 @@ void subscribeShouldSubscribeToStreamAndDispatchesMessage_UnsubscribeShouldUnsub
410410 }
411411
412412 @ Test
413- void subscribeShouldSubscribeToStreamAndDispatchesMessageWithManySubscriptions () {
413+ void subscribeShouldSubscribeToStreamAndDispatchMessageWithManySubscriptions () {
414414 when (locator .metadata ("stream" )).thenReturn (metadata (leader (), null ));
415415
416416 when (clientFactory .client (any ())).thenReturn (client );
You can’t perform that action at this time.
0 commit comments