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

Jump to bottom

testConsumerSwitchOnHanging() fails when using confluent images. #36

Open

cer opened this issue May 12, 2020 · 1 comment

Assignees

Contributor

cer commented May 12, 2020

What's the purpose of this test?

eventuate-messaging-kafka/eventuate-messaging-kafka-spring-basic-consumer/src/test/java/io/eventuate/messaging/kafka/spring/basic/consumer/EventuateKafkaConsumerTest.java

Line 113 in 64a63ef

public void testConsumerSwitchOnHanging() {

cer assigned cer and dartartem

Contributor

dartartem commented May 13, 2020

It tests that if consumer did not commit message, message can be received by new consumer.
First it just handled by mocked handler:

eventuate-messaging-kafka/eventuate-messaging-kafka-spring-basic-consumer/src/test/java/io/eventuate/messaging/kafka/spring/basic/consumer/EventuateKafkaConsumerTest.java

Line 299 in 64a63ef

Eventually.eventually(() -> verify(mockedHandler).apply(any(), any()));

eventuate-messaging-kafka/eventuate-messaging-kafka-spring-basic-consumer/src/test/java/io/eventuate/messaging/kafka/spring/basic/consumer/EventuateKafkaConsumerTest.java

Line 82 in 64a63ef

mockedHandler = mock(EventuateKafkaConsumerMessageHandler.class);

then by real handler/consumer:

eventuate-messaging-kafka/eventuate-messaging-kafka-spring-basic-consumer/src/test/java/io/eventuate/messaging/kafka/spring/basic/consumer/EventuateKafkaConsumerTest.java

Line 280 in 64a63ef

private void assertMessageReceivedByNewConsumer(String value) {

eventuate-messaging-kafka/eventuate-messaging-kafka-spring-basic-consumer/src/test/java/io/eventuate/messaging/kafka/spring/basic/consumer/EventuateKafkaConsumerTest.java

Line 310 in 64a63ef

    
           private EventuateKafkaConsumer createConsumer(EventuateKafkaConsumerMessageHandler handler) {

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment