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

GH-2997 Fix support for producer's error-handler-definition

Browse Source 
Resolves #2997
This commit is contained in:
Oleg Zhurakousky
2024-09-24 17:18:48 +02:00
parent 5d881b2adb
commit 56047ddb19
3 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/spring-cloud-stream-test-binder/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderTests.java
View File

@@ -43,7 +43,7 @@ class TestChannelBinderTests {
"--spring.cloud.stream.bindings.function-in-0.destination=input")) {
TestChannelBinder binder = context.getBean(TestChannelBinder.class);
Method registerErrorInfrastructure = ReflectionUtils
.findMethod(TestChannelBinder.class, "registerErrorInfrastructure", ProducerDestination.class, String.class);
.findMethod(TestChannelBinder.class, "registerErrorInfrastructure", ProducerDestination.class, String.class, boolean.class);
registerErrorInfrastructure.setAccessible(true);
ProducerDestination destination = new ProducerDestination() {
@Override
@@ -56,7 +56,7 @@ class TestChannelBinderTests {
return "sample";
}
};
registerErrorInfrastructure.invoke(binder, destination, "function-in-0");
registerErrorInfrastructure.invoke(binder, destination, "function-in-0", false);
destination = new ProducerDestination() {
@Override
public String getNameForPartition(int partition) {
@@ -68,7 +68,7 @@ class TestChannelBinderTests {
return "sample";
}
};
registerErrorInfrastructure.invoke(binder, destination, "function-in-0");
registerErrorInfrastructure.invoke(binder, destination, "function-in-0", false);
}
}