diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
index 2957165ae30..f7b06d8be3c 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
@@ -177,8 +177,7 @@ class MessagingRSocket implements RSocket {
 					}
 				})
 				.thenMany(Flux.defer(() -> responseRef.get() != null ?
-						responseRef.get() :
-						Mono.error(new IllegalStateException("Something went wrong: reply Mono not set"))));
+						responseRef.get() : Mono.error(new IllegalStateException("Expected response"))));
 	}
 
 	private DataBuffer retainDataAndReleasePayload(Payload payload) {