public class MessageHub extends Object implements AsyncStoppable
| Constructor and Description |
|---|
MessageHub(String displayName,
String nodeName,
ExecutorFactory executorFactory,
IdGenerator<?> idGenerator,
ClassLoader messagingClassLoader) |
| Modifier and Type | Method and Description |
|---|---|
void |
addConnection(Connection<Message> connection)
Adds an incoming connection.
|
void |
addIncoming(String channel,
Dispatch<Object> dispatch) |
Dispatch<Object> |
addMulticastOutgoing(String channel) |
Dispatch<Object> |
addUnicastOutgoing(String channel) |
void |
requestStop()
Requests that this stoppable commence a graceful stop.
|
void |
stop()
Requests a graceful stop of this object.
|
public MessageHub(String displayName, String nodeName, ExecutorFactory executorFactory, IdGenerator<?> idGenerator, ClassLoader messagingClassLoader)
public void addConnection(Connection<Message> connection)
public void requestStop()
AsyncStoppableRequests that this stoppable commence a graceful stop. Does not block. You should call Stoppable.stop() to wait for the stop process to complete.
Generally, an AsyncStoppable should continue to complete existing work after this method has returned.
It should, however, stop accepting new work.
Requesting stopping does not guarantee the stoppable actually stops. Requesting stopping means preparing for stopping; stopping accepting new work. You have to call stop at some point anyway if your intention is to completely stop the stoppable.
requestStop in interface AsyncStoppableCopyright © 2013. All rights reserved