public abstract class ChannelInterceptorAdapter extends java.lang.Object implements ChannelInterceptor
ChannelInterceptor
base class with empty method implementations
as a convenience.Constructor and Description |
---|
ChannelInterceptorAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
afterReceiveCompletion(Message<?> message,
MessageChannel channel,
java.lang.Exception ex)
Invoked after the completion of a receive regardless of any exception that
have been raised thus allowing for proper resource cleanup.
|
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.
|
Message<?> |
postReceive(Message<?> message,
MessageChannel channel)
Invoked immediately after a Message has been retrieved but before
it is returned to the caller.
|
void |
postSend(Message<?> message,
MessageChannel channel,
boolean sent)
Invoked immediately after the send invocation.
|
boolean |
preReceive(MessageChannel channel)
Invoked as soon as receive is called and before a Message is
actually retrieved.
|
Message<?> |
preSend(Message<?> message,
MessageChannel channel)
Invoked before the Message is actually sent to the channel.
|
public Message<?> preSend(Message<?> message, MessageChannel channel)
ChannelInterceptor
null
then the actual
send invocation will not occur.preSend
in interface ChannelInterceptor
public void postSend(Message<?> message, MessageChannel channel, boolean sent)
ChannelInterceptor
postSend
in interface ChannelInterceptor
public void afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, @Nullable java.lang.Exception ex)
ChannelInterceptor
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
.
afterSendCompletion
in interface ChannelInterceptor
public boolean preReceive(MessageChannel channel)
ChannelInterceptor
preReceive
in interface ChannelInterceptor
public Message<?> postReceive(Message<?> message, MessageChannel channel)
ChannelInterceptor
null
aborts further interceptor invocations.
This only applies to PollableChannels.postReceive
in interface ChannelInterceptor
public void afterReceiveCompletion(@Nullable Message<?> message, MessageChannel channel, @Nullable java.lang.Exception ex)
ChannelInterceptor
Note that this will be invoked only if ChannelInterceptor.preReceive(org.springframework.messaging.MessageChannel)
successfully
completed and returned true
.
afterReceiveCompletion
in interface ChannelInterceptor