Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport » [javadoc | source]
org.apache.activemq.transport
abstract public class: TransportSupport [javadoc | source]
java.lang.Object
   org.apache.activemq.util.ServiceSupport
      org.apache.activemq.transport.TransportSupport

All Implemented Interfaces:
    Transport, Service

Direct Known Subclasses:
    XmppTransport, HttpsClientTransport, StompNIOTransport, HttpTransport, UdpTransport, MulticastTransport, HttpTransportSupport, SslTransport, TransportThreadSupport, TcpTransport, HttpsTransport, HttpClientTransport, BlockingQueueTransport, NIOTransport

A useful base class for transport implementations.
Field Summary
 TransportListener transportListener     
Method from org.apache.activemq.transport.TransportSupport Summary:
asyncRequest,   checkStarted,   doConsume,   getTransportListener,   isConnected,   isDisposed,   isFaultTolerant,   narrow,   onException,   reconnect,   request,   request,   setTransportListener
Methods from org.apache.activemq.util.ServiceSupport:
addServiceListener,   dispose,   doStart,   doStop,   isStarted,   isStopped,   isStopping,   removeServiceListener,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.transport.TransportSupport Detail:
 public FutureResponse asyncRequest(Object command,
    ResponseCallback responseCallback) throws IOException 
 protected  void checkStarted() throws IOException 
 public  void doConsume(Object command) 
    Process the inbound command
 public TransportListener getTransportListener() 
    Returns the current transport listener
 public boolean isConnected() 
 public boolean isDisposed() 
 public boolean isFaultTolerant() 
 public T narrow(Class<T> target) 
    narrow acceptance
 public  void onException(IOException e) 
    Passes any IO exceptions into the transport listener
 public  void reconnect(URI uri) throws IOException 
 public Object request(Object command) throws IOException 
 public Object request(Object command,
    int timeout) throws IOException 
 public  void setTransportListener(TransportListener commandListener) 
    Registers an inbound command listener