public class PipeTransportServer extends Object implements TransportServer
Modifier and Type | Field and Description |
---|---|
protected AtomicInteger |
connectionCounter |
protected String |
connectURI |
protected TransportServerListener |
listener |
protected boolean |
marshal |
protected String |
name |
Constructor and Description |
---|
PipeTransportServer() |
Modifier and Type | Method and Description |
---|---|
PipeTransport |
connect() |
protected PipeTransport |
createClientTransport() |
protected PipeTransport |
createServerTransport() |
Executor |
getBlockingExecutor() |
String |
getBoundAddress() |
DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport
|
String |
getName() |
InetSocketAddress |
getSocketAddress() |
boolean |
isMarshal() |
void |
resume()
resume accepting new transports
|
void |
setBlockingExecutor(Executor blockingExecutor) |
void |
setConnectURI(String connectURI) |
void |
setDispatchQueue(DispatchQueue queue)
Sets the dispatch queue used by the transport
|
void |
setMarshal(boolean marshal) |
void |
setName(String name) |
void |
setTransportServerListener(TransportServerListener listener)
Registers an
TransportAcceptListener which is notified of accepted
channels. |
void |
start(Runnable onCompleted)
Deprecated.
|
void |
start(Task onCompleted)
Starts the service.
|
void |
stop(Runnable onCompleted)
Deprecated.
|
void |
stop(Task onCompleted)
Stops the service.
|
void |
suspend()
suspend accepting new transports
|
protected String connectURI
protected TransportServerListener listener
protected boolean marshal
protected final AtomicInteger connectionCounter
public PipeTransportServer()
public String getBoundAddress()
getBoundAddress
in interface TransportServer
public InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
public DispatchQueue getDispatchQueue()
TransportServer
getDispatchQueue
in interface TransportServer
public void setDispatchQueue(DispatchQueue queue)
TransportServer
setDispatchQueue
in interface TransportServer
public void suspend()
TransportServer
suspend
in interface TransportServer
public void resume()
TransportServer
resume
in interface TransportServer
public void setTransportServerListener(TransportServerListener listener)
TransportServer
TransportAcceptListener
which is notified of accepted
channels.setTransportServerListener
in interface TransportServer
@Deprecated public void start(Runnable onCompleted) throws Exception
start
in interface TransportServer
Exception
@Deprecated public void stop(Runnable onCompleted) throws Exception
stop
in interface TransportServer
Exception
public void start(Task onCompleted) throws Exception
TransportServer
start
in interface TransportServer
onCompleted
- my be set to null if not interested in a callback.Exception
public void stop(Task onCompleted) throws Exception
TransportServer
stop
in interface TransportServer
onCompleted
- my be set to null if not interested in a callback.Exception
public void setConnectURI(String connectURI)
public PipeTransport connect()
protected PipeTransport createClientTransport()
protected PipeTransport createServerTransport()
public boolean isMarshal()
public void setMarshal(boolean marshal)
public Executor getBlockingExecutor()
getBlockingExecutor
in interface TransportServer
public void setBlockingExecutor(Executor blockingExecutor)
setBlockingExecutor
in interface TransportServer
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.