Sync ChannelSendOperator copy in spring-messaging

See gh-22720
2019-04-02 11:06:11 -04:00
parent 89a29598d5
commit 208a1ae0ea
1 changed files with 6 additions and 1 deletions
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/ChannelSendOperator.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/ChannelSendOperator.java
@@ -402,7 +402,12 @@ class ChannelSendOperator<T> extends Mono<Void> implements Scannable {

 		@Override
 		public void onError(Throwable ex) {
-			this.completionSubscriber.onError(ex);
+			try {
+				this.completionSubscriber.onError(ex);
+			}
+			finally {
+				this.writeBarrier.releaseCachedItem();
+			}
 		}

 		@Override