|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.fusesource.hawtdispatch.transport.PipeTransportServer
public class PipeTransportServer
Field Summary | |
---|---|
protected AtomicInteger |
connectionCounter
|
protected String |
connectURI
|
protected TransportServerListener |
listener
|
protected boolean |
marshal
|
protected String |
name
|
Constructor Summary | |
---|---|
PipeTransportServer()
|
Method Summary | |
---|---|
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 |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected String connectURI
protected TransportServerListener listener
protected String name
protected boolean marshal
protected final AtomicInteger connectionCounter
Constructor Detail |
---|
public PipeTransportServer()
Method Detail |
---|
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 void setName(String name)
public String getName()
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |