public interface TransportServer
Transport
objects and then
delivers those objects to a TransportAcceptListener
.Modifier and Type | Method and Description |
---|---|
Executor |
getBlockingExecutor() |
String |
getBoundAddress() |
DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport
|
SocketAddress |
getSocketAddress() |
void |
resume()
resume accepting new transports
|
void |
setBlockingExecutor(Executor blockingExecutor) |
void |
setDispatchQueue(DispatchQueue queue)
Sets the dispatch queue used by the transport
|
void |
setTransportServerListener(TransportServerListener acceptListener)
Registers an
TransportAcceptListener which is notified of accepted
channels. |
void |
start(Runnable onComplete) |
void |
start(Task onComplete)
Starts the service.
|
void |
stop(Runnable onComplete) |
void |
stop(Task onComplete)
Stops the service.
|
void |
suspend()
suspend accepting new transports
|
void start(Task onComplete) throws Exception
onComplete
- my be set to null if not interested in a callback.Exception
void stop(Task onComplete) throws Exception
onComplete
- my be set to null if not interested in a callback.Exception
void setTransportServerListener(TransportServerListener acceptListener)
TransportAcceptListener
which is notified of accepted
channels.acceptListener
- String getBoundAddress()
SocketAddress getSocketAddress()
DispatchQueue getDispatchQueue()
void setDispatchQueue(DispatchQueue queue)
queue
- void suspend()
void resume()
Executor getBlockingExecutor()
void setBlockingExecutor(Executor blockingExecutor)
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.