org.apache.catalina.tribes.group.interceptors
public class MessageDispatchInterceptor extends ChannelInterceptorBase implements Runnable
Channel.SEND_OPTIONS_ASYNCHRONOUS
flag to be set, if it is, it will queue the message for delivery and immediately return to the sender.
Version: 1.0
Field Summary | |
---|---|
protected boolean | alwaysSend |
protected long | currentSize |
protected static Log | log |
protected long | maxQueueSize |
protected Thread | msgDispatchThread |
protected FastQueue | queue |
protected boolean | run |
protected boolean | useDeepClone |
Constructor Summary | |
---|---|
MessageDispatchInterceptor() |
Method Summary | |
---|---|
long | addAndGetCurrentSize(long inc) |
boolean | addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) |
long | getCurrentSize() |
long | getMaxQueueSize() |
boolean | getUseDeepClone() |
boolean | isAlwaysSend() |
LinkObject | removeFromQueue() |
void | run() |
protected LinkObject | sendAsyncData(LinkObject link) |
void | sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) |
void | setAlwaysSend(boolean alwaysSend) |
long | setAndGetCurrentSize(long value) |
void | setMaxQueueSize(long maxQueueSize) |
void | setOptionFlag(int flag) |
void | setUseDeepClone(boolean useDeepClone) |
void | start(int svc) |
void | startQueue() |
void | stop(int svc) |
void | stopQueue() |