|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.TransportFilter
public class TransportFilter
Field Summary | |
---|---|
protected Transport |
next
|
protected TransportListener |
transportListener
|
Constructor Summary | |
---|---|
TransportFilter(Transport next)
|
Method Summary | |
---|---|
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
Transport |
getNext()
|
java.lang.String |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
java.lang.Object |
narrow(java.lang.Class target)
|
void |
onCommand(java.lang.Object command)
called to process a command |
void |
oneway(java.lang.Object command)
A one way asynchronous send |
void |
onException(java.io.IOException error)
An unrecoverable exception has occured on the transport |
java.lang.Object |
request(java.lang.Object command)
A synchronous request response |
java.lang.Object |
request(java.lang.Object command,
int timeout)
A synchronous request response |
void |
setTransportListener(TransportListener channelListener)
Registers an inbound command listener |
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
void |
transportInterupted()
The transport has suffered an interuption from which it hopes to recover |
void |
transportResumed()
The transport has resumed after an interuption |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected final Transport next
protected TransportListener transportListener
Constructor Detail |
---|
public TransportFilter(Transport next)
Method Detail |
---|
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener channelListener)
Transport
setTransportListener
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 stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
Service.stop()
public void onCommand(java.lang.Object command)
TransportListener
onCommand
in interface TransportListener
public Transport getNext()
public java.lang.String toString()
toString
in class java.lang.Object
public void oneway(java.lang.Object command) throws java.io.IOException
Transport
oneway
in interface Transport
java.io.IOException
public FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODO
java.io.IOException
public java.lang.Object request(java.lang.Object command) throws java.io.IOException
Transport
request
in interface Transport
java.io.IOException
public java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
Transport
request
in interface Transport
java.io.IOException
public void onException(java.io.IOException error)
TransportListener
onException
in interface TransportListener
public void transportInterupted()
TransportListener
transportInterupted
in interface TransportListener
public void transportResumed()
TransportListener
transportResumed
in interface TransportListener
public java.lang.Object narrow(java.lang.Class target)
narrow
in interface Transport
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |