|
|
@ -104,7 +104,7 @@ public class ReactorMessageChannel implements SubscribableChannel<Message<?>, Me |
|
|
|
logger.trace("Channel " + getName() + ", removing subscription for handler " + handler); |
|
|
|
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 (registration == null) { |
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
logger.trace("Channel " + getName() + ", no subscription for handler " + handler); |
|
|
|
logger.trace("Channel " + getName() + ", no subscription for handler " + handler); |
|
|
|