From f7f66f2e5c18a614a7d741b5ca3d6a07cb49fd8e Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@gopivotal.com>
Date: Mon, 24 Jun 2013 09:59:27 -0400
Subject: [PATCH] Fix minor issue in ReactorMessageChannel

---
 .../web/messaging/support/ReactorMessageChannel.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-websocket/src/main/java/org/springframework/web/messaging/support/ReactorMessageChannel.java b/spring-websocket/src/main/java/org/springframework/web/messaging/support/ReactorMessageChannel.java
index 304cc04163..318c34ce7b 100644
--- a/spring-websocket/src/main/java/org/springframework/web/messaging/support/ReactorMessageChannel.java
+++ b/spring-websocket/src/main/java/org/springframework/web/messaging/support/ReactorMessageChannel.java
@@ -104,7 +104,7 @@ public class ReactorMessageChannel implements SubscribableChannel<Message<?>, Me
 			logger.trace("Channel " + getName() + ", removing subscription for handler " + handler);
 		}
 
-		Registration<?> registration = this.registrations.get(handler);
+		Registration<?> registration = this.registrations.remove(handler);
 		if (registration == null) {
 			if (logger.isTraceEnabled()) {
 				logger.trace("Channel " + getName() + ", no subscription for handler " + handler);