From 51fb49be344524abd4a92098a8a62c83d62ecb9a Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@vmware.com>
Date: Fri, 23 Oct 2020 17:04:44 +0100
Subject: [PATCH] Correct outdated error message

---
 .../messaging/rsocket/annotation/support/MessagingRSocket.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 2957165ae3..f7b06d8be3 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) {