org.apache.synapse.transport.passthru

Class PassThroughHttpSender

java.lang.Object

org.apache.axis2.handlers.AbstractHandler

org.apache.synapse.transport.passthru.PassThroughHttpSender

All Implemented Interfaces:

org.apache.axis2.engine.Handler, org.apache.axis2.transport.TransportSender

Direct Known Subclasses:

PassThroughHttpSSLSender

public class PassThroughHttpSender
extends org.apache.axis2.handlers.AbstractHandler
implements org.apache.axis2.transport.TransportSender

PassThroughHttpSender for Synapse based on HttpCore and NIO extensions

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler

org.apache.axis2.engine.Handler.InvocationResponse

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	log

Fields inherited from class org.apache.axis2.handlers.AbstractHandler

handlerDesc

Constructor Summary

Constructors

Constructor and Description
PassThroughHttpSender()

Method Summary

Modifier and Type	Method and Description
void	cleanup(org.apache.axis2.context.MessageContext messageContext)
protected org.apache.http.nio.reactor.IOEventDispatch	getEventDispatch(org.apache.http.nio.NHttpClientEventHandler handler, SSLContext sslContext, org.apache.http.nio.reactor.ssl.SSLSetupHandler sslIOSessionHandler, org.apache.http.config.ConnectionConfig config, org.apache.axis2.description.TransportOutDescription trpOut) Return the IOEventDispatch implementation to be used.
protected SSLContext	getSSLContext(org.apache.axis2.description.TransportOutDescription transportOut) Always return null, as this implementation does not support outgoing SSL
protected org.apache.http.nio.reactor.ssl.SSLSetupHandler	getSSLSetupHandler(org.apache.axis2.description.TransportOutDescription transportOut) Create the SSL IO Session handler to be used by this listener
void	init(org.apache.axis2.context.ConfigurationContext configurationContext, org.apache.axis2.description.TransportOutDescription transportOutDescription)
org.apache.axis2.engine.Handler.InvocationResponse	invoke(org.apache.axis2.context.MessageContext msgContext)
void	maintenanceShutdown(long millis)
void	pause()
void	resume()
void	stop()
void	submitResponse(org.apache.axis2.context.MessageContext msgContext)

Methods inherited from class org.apache.axis2.handlers.AbstractHandler

flowComplete, getHandlerDesc, getName, getParameter, init, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.axis2.engine.Handler

flowComplete, getHandlerDesc, getName, getParameter, init

Field Detail

log

protected org.apache.commons.logging.Log log

Constructor Detail

PassThroughHttpSender

public PassThroughHttpSender()

Method Detail

init

public void init(org.apache.axis2.context.ConfigurationContext configurationContext,
                 org.apache.axis2.description.TransportOutDescription transportOutDescription)
          throws org.apache.axis2.AxisFault

Specified by:

init in interface org.apache.axis2.transport.TransportSender

Throws:

org.apache.axis2.AxisFault

cleanup

public void cleanup(org.apache.axis2.context.MessageContext messageContext)
             throws org.apache.axis2.AxisFault

Specified by:

cleanup in interface org.apache.axis2.transport.TransportSender

Throws:

org.apache.axis2.AxisFault

stop

public void stop()

Specified by:

stop in interface org.apache.axis2.transport.TransportSender

invoke

public org.apache.axis2.engine.Handler.InvocationResponse invoke(org.apache.axis2.context.MessageContext msgContext)
                                                          throws org.apache.axis2.AxisFault

Specified by:

invoke in interface org.apache.axis2.engine.Handler

Throws:

org.apache.axis2.AxisFault

getEventDispatch

protected org.apache.http.nio.reactor.IOEventDispatch getEventDispatch(org.apache.http.nio.NHttpClientEventHandler handler,
                                                                       SSLContext sslContext,
                                                                       org.apache.http.nio.reactor.ssl.SSLSetupHandler sslIOSessionHandler,
                                                                       org.apache.http.config.ConnectionConfig config,
                                                                       org.apache.axis2.description.TransportOutDescription trpOut)
                                                                throws org.apache.axis2.AxisFault

Return the IOEventDispatch implementation to be used. This is overridden by the SSL sender

Parameters:

handler - The passthru target handler instance

sslContext - SSL context used by the sender or null

sslIOSessionHandler - SSL session handler or null

config - ConnectionConfig instance

trpOut - Transport out description

Returns:

an IOEventDispatch instance

Throws:

org.apache.axis2.AxisFault - on error

getSSLContext

protected SSLContext getSSLContext(org.apache.axis2.description.TransportOutDescription transportOut)
                            throws org.apache.axis2.AxisFault

Always return null, as this implementation does not support outgoing SSL

Parameters:

transportOut - The transport out description

Returns:

null

Throws:

org.apache.axis2.AxisFault - on error

getSSLSetupHandler

protected org.apache.http.nio.reactor.ssl.SSLSetupHandler getSSLSetupHandler(org.apache.axis2.description.TransportOutDescription transportOut)
                                                                      throws org.apache.axis2.AxisFault

Create the SSL IO Session handler to be used by this listener

Parameters:

transportOut - Transport out description

Returns:

always null

Throws:

org.apache.axis2.AxisFault - on error

submitResponse

public void submitResponse(org.apache.axis2.context.MessageContext msgContext)
                    throws IOException,
                           org.apache.http.HttpException

Throws:

IOException

org.apache.http.HttpException

pause

public void pause()
           throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

resume

public void resume()
            throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

maintenanceShutdown

public void maintenanceShutdown(long millis)
                         throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault