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