Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Downgrade to AssertJ 2.5 for Boot compatibility

Browse Source 
See https://github.com/spring-projects/spring-kafka/issues/196
This commit is contained in:
Artem Bilan
2016-10-19 17:29:02 -04:00
committed by Artem Bilan
parent 8cd471532d
commit 696376c728
1 changed files with 20 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
View File

@@ -17,7 +17,7 @@
package org.springframework.integration.kafka.config.xml;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
import static org.junit.Assert.fail;
import static org.mockito.Mockito.mock;
import java.util.concurrent.ExecutionException;
@@ -102,18 +102,28 @@ public class KafkaOutboundAdapterParserTests {
return null;
});
assertThatExceptionOfType(MessageHandlingException.class)
.isThrownBy(() -> handler.handleMessage(new GenericMessage<>("foo")))
.withMessageContaining("Async Producer Mock exception")
.withCauseExactlyInstanceOf(ExecutionException.class)
.withRootCauseExactlyInstanceOf(RuntimeException.class);
try {
handler.handleMessage(new GenericMessage<>("foo"));
fail("MessageHandlingException expected");
}
catch (Exception e) {
assertThat(e).isInstanceOf(MessageHandlingException.class);
assertThat(e.getCause()).isExactlyInstanceOf(ExecutionException.class);
assertThat(e.getCause().getCause()).isInstanceOf(RuntimeException.class);
assertThat(e.getMessage()).contains("Async Producer Mock exception");
}
handler.setSendTimeout(1);
assertThatExceptionOfType(MessageTimeoutException.class)
.isThrownBy(() -> handler.handleMessage(new GenericMessage<>("foo")))
.withMessageContaining("Timeout waiting for response from KafkaProducer")
.withCauseExactlyInstanceOf(TimeoutException.class);
try {
handler.handleMessage(new GenericMessage<>("foo"));
fail("MessageTimeoutException expected");
}
catch (Exception e) {
assertThat(e).isInstanceOf(MessageTimeoutException.class);
assertThat(e.getCause()).isExactlyInstanceOf(TimeoutException.class);
assertThat(e.getMessage()).contains("Timeout waiting for response from KafkaProducer");
}
}
}