public class ClientMessagePool extends Object
| Constructor and Description |
|---|
ClientMessagePool(RouterContext context)Create a new ClientMessagePool. |
| Modifier and Type | Method and Description |
|---|---|
void | add(ClientMessage msg)Add a new client message to the pool. |
void | add(ClientMessage msg,
boolean isDefinitelyRemote)Add a new client message with knowledge of whether it's remote. |
OutboundCache | getCache()Get the outbound cache for this message pool. |
void | restart()Restart the client message pool. |
void | shutdown()Shutdown the client message pool and clear all caches. |
public ClientMessagePool(RouterContext context)
context - the router contextpublic void add(ClientMessage msg)
msg - the ClientMessage to addpublic void add(ClientMessage msg, boolean isDefinitelyRemote)
msg - the ClientMessage to addisDefinitelyRemote - true if we know for sure that the target is not localpublic OutboundCache getCache()
public void restart()
public void shutdown()