org.apache.synapse.transport.passthru

Class PassThroughHttpListener

java.lang.Object

org.apache.synapse.transport.passthru.PassThroughHttpListener

All Implemented Interfaces:

org.apache.axis2.transport.TransportListener

Direct Known Subclasses:

PassThroughHttpSSLListener

public class PassThroughHttpListener
extends Object
implements org.apache.axis2.transport.TransportListener

This is the TransportListener listening for incoming connections. This class start the IOReactor and registers the InRequest Handlers on it.

Field Summary

Fields

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

Fields inherited from interface org.apache.axis2.transport.TransportListener

HOST_ADDRESS, PARAM_PORT

Constructor Summary

Constructors

Constructor and Description
PassThroughHttpListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
org.apache.axis2.addressing.EndpointReference[]	getEPRsForService(String serviceName, String ip) Return the EPRs for the given service over this transport
protected org.apache.http.nio.reactor.IOEventDispatch	getEventDispatch(org.apache.http.nio.NHttpServerEventHandler handler, SSLContext sslContext, org.apache.http.nio.reactor.ssl.SSLSetupHandler sslSetupHandler, org.apache.http.config.ConnectionConfig config)
org.apache.axis2.context.SessionContext	getSessionContext(org.apache.axis2.context.MessageContext messageContext)
protected SSLContext	getSSLContext(org.apache.axis2.description.TransportInDescription transportIn) Create the SSLContext to be used by this listener
protected org.apache.http.nio.reactor.ssl.SSLSetupHandler	getSSLSetupHandler(org.apache.axis2.description.TransportInDescription transportOut) Create the SSL IO Session handler to be used by this listener
void	init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription transportInDescription)
void	maintenanceShutdown(long milliSecs) Stop accepting new connections, and wait the maximum specified time for in-flight requests to complete before a controlled shutdown for maintenance
void	pause() Pause the listener - Stops accepting new connections, but continues processing existing connections until they complete.
void	resume() Resume the lister - Brings the lister into active mode back from a paused state
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.commons.logging.Log log

Constructor Detail

PassThroughHttpListener

public PassThroughHttpListener()

Method Detail

init

public void init(org.apache.axis2.context.ConfigurationContext cfgCtx,
        org.apache.axis2.description.TransportInDescription transportInDescription)
          throws org.apache.axis2.AxisFault

Specified by:

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

Throws:

org.apache.axis2.AxisFault

start

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

Specified by:

start in interface org.apache.axis2.transport.TransportListener

Throws:

org.apache.axis2.AxisFault

getEPRsForService

public org.apache.axis2.addressing.EndpointReference[] getEPRsForService(String serviceName,
                                                                String ip)
                                                                  throws org.apache.axis2.AxisFault

Return the EPRs for the given service over this transport

Specified by:

getEPRsForService in interface org.apache.axis2.transport.TransportListener

Parameters:

serviceName - name of the service

ip - IP address

Returns:

the EndpointReferences for this service over the transport

Throws:

org.apache.axis2.AxisFault - on error

getSessionContext

public org.apache.axis2.context.SessionContext getSessionContext(org.apache.axis2.context.MessageContext messageContext)

Specified by:

getSessionContext in interface org.apache.axis2.transport.TransportListener

stop

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

Specified by:

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

Throws:

org.apache.axis2.AxisFault

destroy

public void destroy()

Specified by:

destroy in interface org.apache.axis2.transport.TransportListener

pause

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

Pause the listener - Stops accepting new connections, but continues processing existing connections until they complete. This helps bring an instance into a maintenance mode

Throws:

org.apache.axis2.AxisFault - if pausing fails

resume

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

Resume the lister - Brings the lister into active mode back from a paused state

Throws:

org.apache.axis2.AxisFault - if the resume fails

maintenanceShutdown

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

Stop accepting new connections, and wait the maximum specified time for in-flight requests to complete before a controlled shutdown for maintenance

Parameters:

milliSecs - number of milliseconds to wait until pending requests complete

Throws:

org.apache.axis2.AxisFault - if the shutdown fails

getEventDispatch

protected org.apache.http.nio.reactor.IOEventDispatch getEventDispatch(org.apache.http.nio.NHttpServerEventHandler handler,
                                                           SSLContext sslContext,
                                                           org.apache.http.nio.reactor.ssl.SSLSetupHandler sslSetupHandler,
                                                           org.apache.http.config.ConnectionConfig config)

getSSLContext

protected SSLContext getSSLContext(org.apache.axis2.description.TransportInDescription transportIn)
                            throws org.apache.axis2.AxisFault

Create the SSLContext to be used by this listener

Parameters:

transportIn - transport in description

Returns:

always null

Throws:

org.apache.axis2.AxisFault - never thrown

getSSLSetupHandler

protected org.apache.http.nio.reactor.ssl.SSLSetupHandler getSSLSetupHandler(org.apache.axis2.description.TransportInDescription 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