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

Fix ErrorBindingTests

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-06-07 12:22:22 +02:00
parent 3c946e8c3d
commit 3a7ab48d51
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/ErrorBindingTests.java
View File

@@ -17,8 +17,8 @@
package org.springframework.cloud.stream.binder;
import java.util.function.Consumer;
import java.util.function.Function;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.WebApplicationType;
@@ -39,7 +39,6 @@ import static org.assertj.core.api.Assertions.assertThat;
public class ErrorBindingTests {
@Test
@Disabled
public void testConfigurationWithDefaultErrorHandler() {
ApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
@@ -61,7 +60,6 @@ public class ErrorBindingTests {
}
@Test
@Disabled
void testConfigurationWithBindingSpecificErrorHandler() {
ApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
@@ -92,6 +90,13 @@ public class ErrorBindingTests {
private int counter;
@Bean
public Function<String, String> handle() {
return v -> {
this.counter++;
throw new RuntimeException("Intentional");
};
}
@Bean
public Consumer<Object> errorHandler() {
@@ -107,6 +112,14 @@ public class ErrorBindingTests {
private int counter;
@Bean
public Function<String, String> handle() {
return v -> {
this.counter++;
throw new RuntimeException("Intentional");
};
}
@Bean
public Consumer<Object> errorHandler() {
return v -> {