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

Polishing for EnableKafkaIntegrationTests

Browse Source 
https://build.spring.io/browse/SK-MAS-292
This commit is contained in:
Artem Bilan
2017-11-30 15:06:03 -05:00
parent d500a29580
commit 6b27ebc50d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
View File

@@ -45,6 +45,7 @@ import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;
import org.springframework.beans.DirectFieldAccessor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -319,8 +320,7 @@ public class EnableKafkaIntegrationTests {
Object messageListener = container.getContainerProperties().getMessageListener();
DefaultJackson2JavaTypeMapper typeMapper = KafkaTestUtils.getPropertyValue(messageListener,
"messageConverter.typeMapper", DefaultJackson2JavaTypeMapper.class);
new DirectFieldAccessor(typeMapper).setPropertyValue("typePrecedence",
Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
typeMapper.setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
assertThat(container).isNotNull();
Foo foo = new Foo();
foo.setBar("bar");