org.ow2.petals.se.eip.listener
Class JBIListener

java.lang.Object
  org.ow2.petals.component.framework.listener.AbstractListener
      org.ow2.petals.component.framework.listener.AbstractJBIListener
          org.ow2.petals.se.eip.listener.JBIListener

All Implemented Interfaces:

ExchangeContext

public class JBIListener
extends org.ow2.petals.component.framework.listener.AbstractJBIListener
implements ExchangeContext

Author:

alouis

Field Summary

Fields inherited from class org.ow2.petals.component.framework.listener.AbstractListener

component, factory, messageInterceptorProcessor

Constructor Summary

JBIListener()

Method Summary

java.util.List<org.ow2.petals.component.framework.jbidescriptor.generated.Consumes>	getSUConsumes(javax.jbi.servicedesc.ServiceEndpoint endpoint) Return the Consumes elements of the service unit that contains the provided endpoint
boolean	onAsyncJBIMessage(org.ow2.petals.component.framework.api.message.Exchange asyncExchange, org.ow2.petals.component.framework.process.async.AsyncContext asyncContext)
boolean	onExpiredAsyncJBIMessage(org.ow2.petals.component.framework.api.message.Exchange exchange, org.ow2.petals.component.framework.process.async.AsyncContext asyncContext)
boolean	onJBIMessage(org.ow2.petals.component.framework.api.message.Exchange exchange)
protected boolean	process(org.ow2.petals.component.framework.api.message.Exchange exchange, CommonAsyncContext asyncContext, boolean expired) Check for the action defined in the SU and call the related Pattern processor
protected void	processAsyncResponse(org.ow2.petals.component.framework.api.message.Exchange exchange) Process a response from a previous asynchronous send performed by the EIP component DONE and ERROR response are catch previously by the framework, so this response is a Fault or an OUT message.

Methods inherited from class org.ow2.petals.component.framework.listener.AbstractListener

createConsumeExchange, createConsumeExchange, createExchange, getComponent, getComponentContext, getConsumes, getCurrentTransaction, getExtensions, getInstallRoot, getLogger, getMessageInterceptorProcessor, getProvides, init, init, retrievePattern, send, sendAsync, sendSync, sendSync, setConsumes, setCurrentTransaction, setExtensions, setProvides

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.ow2.petals.se.eip.ExchangeContext

createConsumeExchange, getExtensions, getLogger, send, sendAsync, sendSync

Constructor Detail

JBIListener

public JBIListener()

Method Detail

getSUConsumes

public java.util.List<org.ow2.petals.component.framework.jbidescriptor.generated.Consumes> getSUConsumes(javax.jbi.servicedesc.ServiceEndpoint endpoint)

Return the Consumes elements of the service unit that contains the provided endpoint

Specified by:

getSUConsumes in interface ExchangeContext

Parameters:

endpoint -

Returns:

a list of Consumes elements related to the provided endpoint

onAsyncJBIMessage

public boolean onAsyncJBIMessage(org.ow2.petals.component.framework.api.message.Exchange asyncExchange,
                                 org.ow2.petals.component.framework.process.async.AsyncContext asyncContext)

Overrides:

onAsyncJBIMessage in class org.ow2.petals.component.framework.listener.AbstractJBIListener

onExpiredAsyncJBIMessage

public boolean onExpiredAsyncJBIMessage(org.ow2.petals.component.framework.api.message.Exchange exchange,
                                        org.ow2.petals.component.framework.process.async.AsyncContext asyncContext)

Overrides:

onExpiredAsyncJBIMessage in class org.ow2.petals.component.framework.listener.AbstractJBIListener

onJBIMessage

public boolean onJBIMessage(org.ow2.petals.component.framework.api.message.Exchange exchange)

Specified by:

onJBIMessage in class org.ow2.petals.component.framework.listener.AbstractJBIListener

process

protected boolean process(org.ow2.petals.component.framework.api.message.Exchange exchange,
                          CommonAsyncContext asyncContext,
                          boolean expired)

Check for the action defined in the SU and call the related Pattern processor

Parameters:

exchange -

processAsyncResponse

protected void processAsyncResponse(org.ow2.petals.component.framework.api.message.Exchange exchange)

Process a response from a previous asynchronous send performed by the EIP component DONE and ERROR response are catch previously by the framework, so this response is a Fault or an OUT message. Do nothing, the framework will send back a DONE status