org.jboss.soa.esb.listeners.old
Class HttpListener

java.lang.Object
  extended by org.jboss.soa.esb.listeners.old.AbstractListener
      extended by org.jboss.soa.esb.listeners.old.AbstractPassiveListener
          extended by org.jboss.soa.esb.listeners.old.HttpListener
All Implemented Interfaces:
java.lang.Runnable, org.jboss.remoting.ServerInvocationHandler

public class HttpListener
extends AbstractPassiveListener
implements org.jboss.remoting.ServerInvocationHandler

Author:
Johan Kumps

Nested Class Summary
 
Nested classes/interfaces inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
AbstractListener.ActionProcessingPipeline
 
Field Summary
 java.lang.String listenHttpUrl
           
 
Fields inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
listenerConfig, logger, m_iMaxThr, m_iQthr, m_iSleepForThreads, m_iUpperThreadLimit, m_oActionDefinitionFactory, m_oActions, m_oDad, m_oMsgFactory, m_oThrGrp, MESSAGE_PROCESSING_ACTIONS_LIST
 
Constructor Summary
HttpListener(GpListener p_oDad, ConfigTree p_oParms, ActionDefinitionFactory actionDefinitionFactory)
           
 
Method Summary
 void addListener(org.jboss.remoting.callback.InvokerCallbackHandler arg0)
           
protected  void checkParams()
          Check for mandatory and optional attributes in parameter tree
protected  void close()
          Close the listener implemenation.
 java.lang.Object invoke(org.jboss.remoting.InvocationRequest invocationRequest)
           
protected  void processingComplete(java.lang.Object initialMsg)
          Called on the listener implementation when pipeline processing of a message is complete.
protected  void processingError(java.lang.Object initialMsg, ActionProcessor processor, java.lang.Throwable error)
          Called on the listener implementation when pipeline processing error has occured.
 void removeListener(org.jboss.remoting.callback.InvokerCallbackHandler arg0)
           
 void setInvoker(org.jboss.remoting.ServerInvoker arg0)
           
 void setMBeanServer(javax.management.MBeanServer arg0)
           
 
Methods inherited from class org.jboss.soa.esb.listeners.old.AbstractPassiveListener
receive
 
Methods inherited from class org.jboss.soa.esb.listeners.old.AbstractListener
run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

listenHttpUrl

public java.lang.String listenHttpUrl
Constructor Detail

HttpListener

public HttpListener(GpListener p_oDad,
                    ConfigTree p_oParms,
                    ActionDefinitionFactory actionDefinitionFactory)
             throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

checkParams

protected void checkParams()
                    throws java.lang.Exception
Check for mandatory and optional attributes in parameter tree

Throws:
java.lang.Exception - - if actionClass not specified or not in classpath or invalid int values for maxThreads or pollLatencySecs

invoke

public java.lang.Object invoke(org.jboss.remoting.InvocationRequest invocationRequest)
                        throws java.lang.Throwable
Specified by:
invoke in interface org.jboss.remoting.ServerInvocationHandler
Throws:
java.lang.Throwable

processingError

protected void processingError(java.lang.Object initialMsg,
                               ActionProcessor processor,
                               java.lang.Throwable error)
Description copied from class: AbstractListener
Called on the listener implementation when pipeline processing error has occured.

Specified by:
processingError in class AbstractListener
Parameters:
initialMsg - The message that was initialy supplied to the pipeline.
processor - The processor that raised the error. Can be null where the error was raised before pipeline processing of the message.
error - The error. Can be null.

processingComplete

protected void processingComplete(java.lang.Object initialMsg)
Description copied from class: AbstractListener
Called on the listener implementation when pipeline processing of a message is complete.

Specified by:
processingComplete in class AbstractListener
Parameters:
initialMsg - The message that was initialy supplied to the pipeline.

close

protected void close()
Description copied from class: AbstractListener
Close the listener implemenation.

Allows the listener to perform relevant close/cleanup tasks.

Specified by:
close in class AbstractListener

setMBeanServer

public void setMBeanServer(javax.management.MBeanServer arg0)
Specified by:
setMBeanServer in interface org.jboss.remoting.ServerInvocationHandler

setInvoker

public void setInvoker(org.jboss.remoting.ServerInvoker arg0)
Specified by:
setInvoker in interface org.jboss.remoting.ServerInvocationHandler

addListener

public void addListener(org.jboss.remoting.callback.InvokerCallbackHandler arg0)
Specified by:
addListener in interface org.jboss.remoting.ServerInvocationHandler

removeListener

public void removeListener(org.jboss.remoting.callback.InvokerCallbackHandler arg0)
Specified by:
removeListener in interface org.jboss.remoting.ServerInvocationHandler