|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.apollo.transport.TransportFilter
public class TransportFilter
Field Summary | |
---|---|
protected Transport |
next
|
protected TransportListener |
transportListener
|
Constructor Summary | |
---|---|
TransportFilter(Transport next)
|
Method Summary | ||
---|---|---|
boolean |
full()
|
|
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport |
|
Transport |
getNext()
|
|
ProtocolCodec |
getProtocolCodec()
|
|
java.lang.String |
getRemoteAddress()
|
|
TransportListener |
getTransportListener()
Returns the current transport listener |
|
java.lang.String |
getTypeId()
|
|
boolean |
isConnected()
|
|
boolean |
isDisposed()
|
|
boolean |
isFaultTolerant()
Indicates if the transport can handle faults |
|
|
narrow(java.lang.Class<T> target)
|
|
boolean |
offer(java.lang.Object command)
A one way asynchronous send of a command. |
|
void |
onRefill()
transport can now accept more commands for transmission. |
|
void |
onTransportCommand(java.lang.Object command)
called to process a command |
|
void |
onTransportConnected()
The transport has been connected. |
|
void |
onTransportDisconnected()
The transport has suffered a disconnection from which it hopes to recover |
|
void |
onTransportFailure(java.io.IOException error)
An unrecoverable exception has occured on the transport |
|
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 |
setNext(Transport next)
|
|
void |
setProtocolCodec(ProtocolCodec protocolCodec)
Sets the protocol codec for the transport |
|
void |
setTransportListener(TransportListener listener)
Registers an inbound command listener |
|
void |
start()
|
|
void |
start(java.lang.Runnable onComplete)
|
|
void |
stop()
|
|
void |
stop(java.lang.Runnable onComplete)
|
|
void |
suspendRead()
suspend delivery of commands. |
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected Transport next
protected TransportListener transportListener
Constructor Detail |
---|
public TransportFilter(Transport next)
Method Detail |
---|
public Transport getNext()
public void setNext(Transport next)
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener listener)
Transport
setTransportListener
in interface Transport
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 suspendRead()
Transport
suspendRead
in interface Transport
public void resumeRead()
Transport
resumeRead
in interface Transport
public void start() throws java.lang.Exception
start
in interface Service
java.io.IOException
- if the next channel has not been set.
java.lang.Exception
Service.start()
public void start(java.lang.Runnable onComplete) 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
Service.stop()
public void stop(java.lang.Runnable onComplete) throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public void onTransportCommand(java.lang.Object command)
TransportListener
onTransportCommand
in interface TransportListener
public void onRefill()
TransportListener
onRefill
in interface TransportListener
public java.lang.String toString()
toString
in class java.lang.Object
public boolean offer(java.lang.Object command)
Transport
offer
in interface Transport
public boolean full()
full
in interface Transport
public void onTransportFailure(java.io.IOException error)
TransportListener
onTransportFailure
in interface TransportListener
public void onTransportDisconnected()
TransportListener
onTransportDisconnected
in interface TransportListener
public void onTransportConnected()
TransportListener
onTransportConnected
in interface TransportListener
public <T> T narrow(java.lang.Class<T> target)
narrow
in interface Transport
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
public boolean isFaultTolerant()
Transport
isFaultTolerant
in interface Transport
Transport.isFaultTolerant()
public boolean isDisposed()
isDisposed
in interface Transport
public boolean isConnected()
isConnected
in interface Transport
public java.lang.String getTypeId()
getTypeId
in interface Transport
public void reconnect(java.net.URI uri)
Transport
reconnect
in interface Transport
public ProtocolCodec getProtocolCodec()
getProtocolCodec
in interface Transport
public void setProtocolCodec(ProtocolCodec protocolCodec)
Transport
setProtocolCodec
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |