org.springframework.messaging.simp.broker

Class AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor

java.lang.Object

org.springframework.messaging.support.ChannelInterceptorAdapter

org.springframework.messaging.simp.broker.AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor

All Implemented Interfaces:

ChannelInterceptor

Enclosing class:

AbstractBrokerMessageHandler

private class AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor
extends ChannelInterceptorAdapter

Detect unsent DISCONNECT messages and process them anyway.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	UnsentDisconnectChannelInterceptor()

Method Summary

Modifier and Type	Method and Description
void	afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, java.lang.Exception ex) Invoked after the completion of a send regardless of any exception that have been raised thus allowing for proper resource cleanup.

Methods inherited from class org.springframework.messaging.support.ChannelInterceptorAdapter

afterReceiveCompletion, postReceive, postSend, preReceive, preSend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnsentDisconnectChannelInterceptor

private UnsentDisconnectChannelInterceptor()

Method Detail

afterSendCompletion

public void afterSendCompletion(Message<?> message,
                                MessageChannel channel,
                                boolean sent,
                                java.lang.Exception ex)

Description copied from interface: ChannelInterceptor

Invoked after the completion of a send regardless of any exception that have been raised thus allowing for proper resource cleanup.

Note that this will be invoked only if ChannelInterceptor.preSend(org.springframework.messaging.Message<?>, org.springframework.messaging.MessageChannel) successfully completed and returned a Message, i.e. it did not return null.

Specified by:

afterSendCompletion in interface ChannelInterceptor

Overrides:

afterSendCompletion in class ChannelInterceptorAdapter