Home » synapse-1.2-src » org.apache.synapse.transport.base » [javadoc | source]
org.apache.synapse.transport.base
abstract public class: AbstractTransportSender [javadoc | source]
java.lang.Object
   org.apache.axis2.handlers.AbstractHandler
      org.apache.synapse.transport.base.AbstractTransportSender

All Implemented Interfaces:
    org.apache.axis2.transport.TransportSender

Direct Known Subclasses:
    FIXTransportSender, MailTransportSender, JMSSender, VFSTransportSender, AMQPSender

Field Summary
protected  Log log    the reference to the actual commons logger to be used for log messages 
protected  String transportName    the name of the transport 
protected  ConfigurationContext cfgCtx    the axis2 configuration context 
protected  AxisEngine engine    an axis2 engine over the above configuration context to process messages 
protected  MetricsCollector metrics    Metrics collector for the sender 
Method from org.apache.synapse.transport.base.AbstractTransportSender Summary:
cleanup,   createResponseMessageContext,   getActiveThreadCount,   getBytesReceived,   getBytesSent,   getFaultsReceiving,   getFaultsSending,   getMessagesReceived,   getMessagesSent,   getQueueSize,   getTransportName,   handleException,   handleException,   handleIncomingMessage,   init,   invoke,   logException,   maintenenceShutdown,   pause,   resume,   sendMessage,   setTransportName,   stop,   waitForSynchronousResponse
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.synapse.transport.base.AbstractTransportSender Detail:
 public  void cleanup(MessageContext msgContext) throws AxisFault 
 public MessageContext createResponseMessageContext(MessageContext outMsgCtx) 
    Create a new axis MessageContext for an incoming response message through this transport, for the given outgoing message
 public int getActiveThreadCount() 
    Returns the number of active threads processing messages
 public long getBytesReceived() 
 public long getBytesSent() 
 public long getFaultsReceiving() 
 public long getFaultsSending() 
 public long getMessagesReceived() 
 public long getMessagesSent() 
 public int getQueueSize() 
    Return the number of requests queued in the thread pool
 public String getTransportName() 
 protected  void handleException(String msg) throws AxisFault 
 protected  void handleException(String msg,
    Exception e) throws AxisFault 
 public  void handleIncomingMessage(MessageContext msgCtx,
    Map trpHeaders,
    String soapAction,
    String contentType) 
    Process a new incoming message (Response) through the axis engine
 public  void init(ConfigurationContext cfgCtx,
    TransportOutDescription transportOut) throws AxisFault 
    Initialize the generic transport sender.
 public InvocationResponse invoke(MessageContext msgContext) throws AxisFault 
 protected  void logException(String msg,
    Exception e) 
 public  void maintenenceShutdown(long millis) throws AxisFault 
 public  void pause() throws AxisFault 
 public  void resume() throws AxisFault 
 abstract public  void sendMessage(MessageContext msgCtx,
    String targetEPR,
    OutTransportInfo outTransportInfo) throws AxisFault
 public  void setTransportName(String transportName) 
 public  void stop() 
 protected boolean waitForSynchronousResponse(MessageContext msgCtx) 
    Should the transport sender wait for a synchronous response to be received?