SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SCF-GH-661 Fix tests to validate KafkaNull conversion

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-03-04 16:09:28 +01:00
parent 82929f9bcf
commit 73024136d6
2 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -25,7 +25,7 @@
<java.version>1.8</java.version>
<reactor.version>2020.0.2</reactor.version>
<objenesis.version>2.1</objenesis.version>
<spring-cloud-function.version>3.1.1</spring-cloud-function.version>
<spring-cloud-function.version>3.1.2-SNAPSHOT</spring-cloud-function.version>
<maven-checkstyle-plugin.failsOnError>true</maven-checkstyle-plugin.failsOnError>
<maven-checkstyle-plugin.failsOnViolation>true</maven-checkstyle-plugin.failsOnViolation>
<maven-checkstyle-plugin.includeTestSourceDirectory>true</maven-checkstyle-plugin.includeTestSourceDirectory>

10
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
View File

@@ -1178,14 +1178,8 @@ public class ImplicitFunctionBindingTests {
public Function<Message<Person>, String> funcMessage() {
return value -> {
Object v = value.getPayload();
System.out.println(v.getClass());
if (value.getPayload() instanceof Object) {
System.out.println("");
}
if (((Object) value.getPayload()).getClass() != null) {
System.out.println();
}
//assertThat(value.getPayload().getClass().getName()).isEqualTo("org.springframework.kafka.support.KafkaNull");
String className = v.getClass().getName();
assertThat(className).isEqualTo("org.springframework.kafka.support.KafkaNull");
return "NULL";
};
}