org.apache.servicemix.http.processors
Class ConsumerProcessor

java.lang.Object
  org.apache.servicemix.http.processors.AbstractProcessor
      org.apache.servicemix.http.processors.ConsumerProcessor

All Implemented Interfaces:

HttpProcessor, org.apache.servicemix.soap.SoapExchangeProcessor

public class ConsumerProcessor
extends AbstractProcessor
implements org.apache.servicemix.soap.SoapExchangeProcessor, HttpProcessor

Field Summary

protected javax.jbi.messaging.DeliveryChannel	channel
protected javax.jbi.component.ComponentContext	context
protected Map<String,javax.jbi.messaging.MessageExchange>	exchanges
protected Object	httpContext
protected Map<String,org.mortbay.util.ajax.Continuation>	locks
protected org.apache.servicemix.soap.SoapHelper	soapHelper
protected boolean	started
protected int	suspentionTime

Fields inherited from class org.apache.servicemix.http.processors.AbstractProcessor

endpoint, HEADER_CONTENT_LENGTH, HEADER_CONTENT_TYPE, HEADER_SOAP_ACTION

Constructor Summary

ConsumerProcessor(HttpEndpoint endpoint)

Method Summary

protected void	generateDocument(HttpServletResponse response, Node node)
String	getAuthMethod()
protected Map<String,String>	getHeaders(HttpServletRequest request)
protected ContextManager	getServerManager()
SslParameters	getSsl()
void	init()
void	process(HttpServletRequest request, HttpServletResponse response)
void	process(javax.jbi.messaging.MessageExchange exchange)
protected void	sendFault(org.apache.servicemix.soap.SoapFault fault, HttpServletRequest request, HttpServletResponse response)
void	shutdown()
void	start()
void	stop()

Methods inherited from class org.apache.servicemix.http.processors.AbstractProcessor

getConfiguration

Methods inherited from class java.lang.Object

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

Field Detail

httpContext

protected Object httpContext

context

protected javax.jbi.component.ComponentContext context

channel

protected javax.jbi.messaging.DeliveryChannel channel

soapHelper

protected org.apache.servicemix.soap.SoapHelper soapHelper

locks

protected Map<String,org.mortbay.util.ajax.Continuation> locks

exchanges

protected Map<String,javax.jbi.messaging.MessageExchange> exchanges

suspentionTime

protected int suspentionTime

started

protected boolean started

Constructor Detail

ConsumerProcessor

public ConsumerProcessor(HttpEndpoint endpoint)

Method Detail

getSsl

public SslParameters getSsl()

Specified by:

getSsl in interface HttpProcessor

getAuthMethod

public String getAuthMethod()

Specified by:

getAuthMethod in interface HttpProcessor

process

public void process(javax.jbi.messaging.MessageExchange exchange)
             throws Exception

Specified by:

process in interface org.apache.servicemix.soap.SoapExchangeProcessor

Throws:

Exception

init

public void init()
          throws Exception

Specified by:

init in interface org.apache.servicemix.soap.SoapExchangeProcessor

Throws:

Exception

shutdown

public void shutdown()
              throws Exception

Specified by:

shutdown in interface org.apache.servicemix.soap.SoapExchangeProcessor

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.servicemix.soap.SoapExchangeProcessor

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.servicemix.soap.SoapExchangeProcessor

Throws:

Exception

process

public void process(HttpServletRequest request,
                    HttpServletResponse response)
             throws Exception

Specified by:

process in interface HttpProcessor

Throws:

Exception

sendFault

protected void sendFault(org.apache.servicemix.soap.SoapFault fault,
                         HttpServletRequest request,
                         HttpServletResponse response)
                  throws Exception

Throws:

Exception

getHeaders

protected Map<String,String> getHeaders(HttpServletRequest request)

getServerManager

protected ContextManager getServerManager()

generateDocument

protected void generateDocument(HttpServletResponse response,
                                Node node)
                         throws Exception

Throws:

Exception