diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java index 7fed87066..915260131 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java @@ -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 map = (Map) field.get(bridge); final MessageChannel messageChannel = map.get("test-channel"); assertThat(((DirectWithAttributesChannel) messageChannel).getFullChannelName()).isEqualTo("application.test-channel");