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

Fix compile issues

Browse Source
This commit is contained in:
Soby Chacko
2024-01-19 16:07:34 -05:00
parent e55de656eb
commit 09b408416b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java
View File

@@ -407,7 +407,7 @@ public class StreamBridgeTests {
bridge.send("test-channel", "blah");
Field field = ReflectionUtils.findField(StreamBridge.class, "channelCache");
Objects.requireNonNull(field).setAccessible(true);
field.setAccessible(true);
Map<String, MessageChannel> map = (Map<String, MessageChannel>) field.get(bridge);
final MessageChannel messageChannel = map.get("test-channel");
assertThat(((DirectWithAttributesChannel) messageChannel).getFullChannelName()).isEqualTo("application.test-channel");