org.apache.catalina.tribes.group.interceptors
public class OrderInterceptor extends ChannelInterceptorBase
Version: 1.1
Nested Class Summary | |
---|---|
protected static class | OrderInterceptor.Counter |
protected static class | OrderInterceptor.MessageOrder |
Method Summary | |
---|---|
long | getExpire() |
boolean | getForwardExpired() |
protected OrderInterceptor.Counter | getInCounter(Member mbr) |
int | getMaxQueue() |
protected OrderInterceptor.Counter | getOutCounter(Member mbr) |
protected int | incCounter(Member mbr) |
void | memberAdded(Member member) |
void | memberDisappeared(Member member) |
void | messageReceived(ChannelMessage msg) |
protected boolean | processIncoming(OrderInterceptor.MessageOrder order) |
protected void | processLeftOvers(Member member, boolean force) |
void | sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) |
void | setExpire(long expire) |
void | setForwardExpired(boolean forwardExpired) |
void | setMaxQueue(int maxQueue) |
Parameters: order MessageOrder
Returns: boolean - true if a message expired and was processed