Skip to content

Commit d775490

Browse files
committed
Fixed test failure caused by multiple consumers.
1 parent 474219b commit d775490

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/test/java/io/github/majusko/pulsar/PulsarJavaSpringBootStarterApplicationTests.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,9 @@ void testConsumerRegistration1() throws Exception {
7272

7373
Assertions.assertEquals(2, consumers.size());
7474

75-
final Consumer<?> consumer = consumers.stream().findFirst().orElseThrow(Exception::new);
75+
final Consumer<?> consumer = consumers.stream().filter( $-> $.getTopic().equals("topic-one")).findFirst().orElseThrow(Exception::new);
7676

7777
Assertions.assertNotNull(consumer);
78-
Assertions.assertEquals("topic-one", consumer.getTopic());
7978
}
8079

8180
@Test

0 commit comments

Comments
 (0)