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

Upgrade to SK 2.0 M3, Gradle 4.0.1

Browse Source
This commit is contained in:
Artem Bilan
2017-07-24 17:19:15 -04:00
committed by Artem Bilan
parent c219a43c58
commit 8d15b9582a
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -90,7 +90,14 @@ public class KafkaOutboundAdapterParserTests {
public void testSyncMode() {
@SuppressWarnings("resource")
MockProducer<Integer, String> mockProducer =
new MockProducer<>(false, new IntegerSerializer(), new StringSerializer());
new MockProducer<Integer, String>(false, new IntegerSerializer(), new StringSerializer()) {
@Override
public void close() {
// To avoid non transactional closes.
}
};
KafkaTemplate<Integer, String> template = new KafkaTemplate<>(() -> mockProducer);
KafkaProducerMessageHandler<Integer, String> handler = new KafkaProducerMessageHandler<>(template);
handler.setBeanFactory(mock(BeanFactory.class));