|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.apollo.transport.pipe.PipeTransportServer
public class PipeTransportServer
Field Summary | |
---|---|
protected java.util.concurrent.atomic.AtomicInteger |
connectionCounter
|
protected java.net.URI |
connectURI
|
protected TransportAcceptListener |
listener
|
protected boolean |
marshal
|
protected java.lang.String |
name
|
protected ProtocolCodecFactory.Provider |
protocolCodecFactory
|
Constructor Summary | |
---|---|
PipeTransportServer()
|
Method Summary | |
---|---|
PipeTransport |
connect()
|
protected PipeTransport |
createClientTransport()
|
protected PipeTransport |
createServerTransport()
|
java.lang.String |
getBoundAddress()
|
java.lang.String |
getConnectAddress()
|
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport |
java.lang.String |
getName()
|
java.net.InetSocketAddress |
getSocketAddress()
|
boolean |
isMarshal()
|
void |
resume()
resume accepting new transports |
void |
setAcceptListener(TransportAcceptListener listener)
Registers an TransportAcceptListener which is notified of accepted
channels. |
void |
setConnectURI(java.net.URI connectURI)
|
void |
setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
Sets the dispatch queue used by the transport |
void |
setMarshal(boolean marshal)
|
void |
setName(java.lang.String name)
|
void |
setProtocolCodecFactory(ProtocolCodecFactory.Provider protocolCodecFactory)
|
void |
start()
|
void |
start(java.lang.Runnable onCompleted)
|
void |
stop()
|
void |
stop(java.lang.Runnable onCompleted)
|
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 java.net.URI connectURI
protected TransportAcceptListener listener
protected java.lang.String name
protected ProtocolCodecFactory.Provider protocolCodecFactory
protected boolean marshal
protected final java.util.concurrent.atomic.AtomicInteger connectionCounter
Constructor Detail |
---|
public PipeTransportServer()
Method Detail |
---|
public java.lang.String getBoundAddress()
getBoundAddress
in interface TransportServer
public java.lang.String getConnectAddress()
getConnectAddress
in interface TransportServer
public java.net.InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()
TransportServer
getDispatchQueue
in interface TransportServer
public void setDispatchQueue(org.fusesource.hawtdispatch.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 setAcceptListener(TransportAcceptListener listener)
TransportServer
TransportAcceptListener
which is notified of accepted
channels.
setAcceptListener
in interface TransportServer
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void start(java.lang.Runnable onCompleted) throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public void stop(java.lang.Runnable onCompleted) throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public void setConnectURI(java.net.URI connectURI)
public void setName(java.lang.String name)
public java.lang.String getName()
public PipeTransport connect()
protected PipeTransport createClientTransport()
protected PipeTransport createServerTransport()
public void setProtocolCodecFactory(ProtocolCodecFactory.Provider protocolCodecFactory)
public boolean isMarshal()
public void setMarshal(boolean marshal)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |