public class DefaultMultiChannelConnector extends Object implements MultiChannelConnector, Stoppable
| Constructor and Description |
|---|
DefaultMultiChannelConnector(OutgoingConnector<Message> outgoingConnector,
IncomingConnector<Message> incomingConnector,
ExecutorFactory executorFactory,
ClassLoader messagingClassLoader) |
| Modifier and Type | Method and Description |
|---|---|
Address |
accept(Action<ConnectEvent<MultiChannelConnection<Object>>> action) |
MultiChannelConnection<Object> |
connect(Address destinationAddress) |
void |
stop()
Requests a graceful stop of this object.
|
public DefaultMultiChannelConnector(OutgoingConnector<Message> outgoingConnector, IncomingConnector<Message> incomingConnector, ExecutorFactory executorFactory, ClassLoader messagingClassLoader)
public void stop()
StoppableRequests a graceful stop of this object. Blocks until all concurrent activity has been completed.
If this object has already been stopped, this method does nothing.
public Address accept(Action<ConnectEvent<MultiChannelConnection<Object>>> action)
accept in interface MultiChannelConnectorpublic MultiChannelConnection<Object> connect(Address destinationAddress)
connect in interface MultiChannelConnectorCopyright © 2013. All rights reserved