diff --git a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/MessagingTests.java b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/MessagingTests.java index 03752b142..936354d67 100644 --- a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/MessagingTests.java +++ b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/MessagingTests.java @@ -269,6 +269,8 @@ public class MessagingTests { @Bean public Function>, Message>> echoMessageMap() { return v -> { + assertThat(v.getHeaders()).containsKey("rsocketFrameType"); + assertThat(v.getHeaders()).containsKey("lookupDestination"); return v; }; }