|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.apollo.transport.pipe.PipeTransport
public class PipeTransport
Constructor Summary | |
---|---|
PipeTransport(PipeTransportServer server)
|
Method Summary | ||
---|---|---|
boolean |
full()
|
|
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport |
|
ProtocolCodec |
getProtocolCodec()
|
|
long |
getReadCounter()
|
|
java.lang.String |
getRemoteAddress()
|
|
TransportListener |
getTransportListener()
Returns the current transport listener |
|
java.lang.String |
getTypeId()
|
|
long |
getWriteCounter()
|
|
boolean |
isConnected()
|
|
boolean |
isDisposed()
|
|
boolean |
isFaultTolerant()
Indicates if the transport can handle faults |
|
boolean |
isMarshal()
|
|
boolean |
isTrace()
|
|
|
narrow(java.lang.Class<T> target)
|
|
boolean |
offer(java.lang.Object command)
A one way asynchronous send of a command. |
|
void |
reconnect(java.net.URI uri)
reconnect to another location |
|
void |
resumeRead()
resume delivery of commands. |
|
void |
setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
Sets the dispatch queue used by the transport |
|
void |
setMarshal(boolean marshall)
|
|
void |
setName(java.lang.String name)
|
|
void |
setProtocolCodec(ProtocolCodec protocolCodec)
Sets the protocol codec for the transport |
|
void |
setRemoteAddress(java.lang.String remoteAddress)
|
|
void |
setTrace(boolean trace)
|
|
void |
setTransportListener(TransportListener listener)
Registers an inbound command listener |
|
void |
start()
|
|
void |
start(java.lang.Runnable onCompleted)
|
|
void |
stop()
|
|
void |
stop(java.lang.Runnable onCompleted)
|
|
void |
suspendRead()
suspend delivery of commands. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PipeTransport(PipeTransportServer server)
Method Detail |
---|
public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()
Transport
getDispatchQueue
in interface Transport
public void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
Transport
setDispatchQueue
in interface Transport
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 boolean full()
full
in interface Transport
public boolean offer(java.lang.Object command)
Transport
offer
in interface Transport
public long getWriteCounter()
public long getReadCounter()
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
public <T> T narrow(java.lang.Class<T> target)
narrow
in interface Transport
public void suspendRead()
Transport
suspendRead
in interface Transport
public void resumeRead()
Transport
resumeRead
in interface Transport
public void reconnect(java.net.URI uri)
Transport
reconnect
in interface Transport
public java.lang.String getTypeId()
getTypeId
in interface Transport
public void setRemoteAddress(java.lang.String remoteAddress)
public void setName(java.lang.String name)
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener listener)
Transport
setTransportListener
in interface Transport
public ProtocolCodec getProtocolCodec()
getProtocolCodec
in interface Transport
public void setProtocolCodec(ProtocolCodec protocolCodec)
Transport
setProtocolCodec
in interface Transport
public boolean isTrace()
public void setTrace(boolean trace)
public boolean isMarshal()
public void setMarshal(boolean marshall)
public boolean isConnected()
isConnected
in interface Transport
public boolean isDisposed()
isDisposed
in interface Transport
public boolean isFaultTolerant()
Transport
isFaultTolerant
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |