org.springframework.integration.channel

Class AbstractMessageChannel.ChannelInterceptorList

java.lang.Object

org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

Enclosing class:

AbstractMessageChannel

protected static class AbstractMessageChannel.ChannelInterceptorList
extends Object

A convenience wrapper class for the list of ChannelInterceptors.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<ChannelInterceptor>	interceptors

Constructor Summary

Constructors

Constructor and Description
ChannelInterceptorList(LogAccessor logger)

Method Summary

Modifier and Type	Method and Description
boolean	add(ChannelInterceptor interceptor)
void	add(int index, ChannelInterceptor interceptor)
void	afterReceiveCompletion(Message<?> message, MessageChannel channel, Exception ex, Deque<ChannelInterceptor> interceptorStack)
void	afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, Exception ex, Deque<ChannelInterceptor> interceptorStack)
List<ChannelInterceptor>	getInterceptors()
int	getSize()
Message<?>	postReceive(Message<?> messageArg, MessageChannel channel)
void	postSend(Message<?> message, MessageChannel channel, boolean sent)
boolean	preReceive(MessageChannel channel, Deque<ChannelInterceptor> interceptorStack)
Message<?>	preSend(Message<?> messageArg, MessageChannel channel, Deque<ChannelInterceptor> interceptorStack)
boolean	remove(ChannelInterceptor interceptor)
ChannelInterceptor	remove(int index)
boolean	set(List<ChannelInterceptor> interceptors)

Methods inherited from class java.lang.Object

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

Field Detail

interceptors

protected final List<ChannelInterceptor> interceptors

Constructor Detail

ChannelInterceptorList

public ChannelInterceptorList(LogAccessor logger)

Method Detail

set

public boolean set(List<ChannelInterceptor> interceptors)

getSize

public int getSize()

add

public boolean add(ChannelInterceptor interceptor)

add

public void add(int index,
                ChannelInterceptor interceptor)

preSend

@Nullable
public Message<?> preSend(Message<?> messageArg,
                                    MessageChannel channel,
                                    Deque<ChannelInterceptor> interceptorStack)

postSend

public void postSend(Message<?> message,
                     MessageChannel channel,
                     boolean sent)

afterSendCompletion

public void afterSendCompletion(Message<?> message,
                                MessageChannel channel,
                                boolean sent,
                                @Nullable
                                Exception ex,
                                Deque<ChannelInterceptor> interceptorStack)

preReceive

public boolean preReceive(MessageChannel channel,
                          Deque<ChannelInterceptor> interceptorStack)

postReceive

@Nullable
public Message<?> postReceive(Message<?> messageArg,
                                        MessageChannel channel)

afterReceiveCompletion

public void afterReceiveCompletion(@Nullable
                                   Message<?> message,
                                   MessageChannel channel,
                                   @Nullable
                                   Exception ex,
                                   @Nullable
                                   Deque<ChannelInterceptor> interceptorStack)

getInterceptors

public List<ChannelInterceptor> getInterceptors()

remove

public boolean remove(ChannelInterceptor interceptor)

remove

@Nullable
public ChannelInterceptor remove(int index)