diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequester.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequester.java index 8bdddea5ab..e579c8e11c 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequester.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequester.java @@ -117,7 +117,7 @@ final class DefaultRSocketRequester implements RSocketRequester { private final MetadataEncoder metadataEncoder; @Nullable - private Mono payloadMono = Mono.empty(); + private Mono payloadMono = emptyPayload(); @Nullable private Flux payloadFlux = null;