org.ow2.petals.component.framework.process
Class MessageExchangeProcessor

java.lang.Object
  org.ow2.petals.component.framework.process.MessageExchangeProcessor

All Implemented Interfaces:

java.lang.Runnable

public class MessageExchangeProcessor
extends java.lang.Object
implements java.lang.Runnable

Processor for received MessageExchanges. This processor can be overridden to define a specific strategy to accept messages from the DeliveryChannel. See acceptMessageExchange().
Override the createMessageExchangeProcessor method in the Component class to set your processor.

Since:

2.0

Author:

alouis,ofabre,chamerling - EBM Websourcing

Constructor Summary

MessageExchangeProcessor(AbstractComponent component, AbstractJBIListener jbiListener, java.util.logging.Logger logger)
Creates a processor that listen to new MessageExchange on the specified channel.

Method Summary

protected void	clean() Clean the Message Exchange Processor.
ExchangeImpl	getMessageExchange() Get the current processing exchange.
protected org.ow2.petals.commons.logger.ProvideFlowStepBeginLogData	newProvideFlowStepBeginLogData(org.ow2.petals.component.framework.api.message.Exchange exchange)
void	run()
void	setMessageExchange(ExchangeImpl exchange) Set the current exchange to process.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageExchangeProcessor

public MessageExchangeProcessor(AbstractComponent component,
                                AbstractJBIListener jbiListener,
                                java.util.logging.Logger logger)

Creates a processor that listen to new MessageExchange on the specified channel. Exchanges are ignored depending on the specified exchange-status to ignore.

Parameters:

component -

jbiPool -

exchange -

Method Detail

setMessageExchange

public void setMessageExchange(ExchangeImpl exchange)

Set the current exchange to process.

Parameters:

exchange -

getMessageExchange

public ExchangeImpl getMessageExchange()

Get the current processing exchange.

Parameters:

exchange -

run

public void run()

Specified by:

run in interface java.lang.Runnable

clean

protected final void clean()

Clean the Message Exchange Processor. It cleans all the resources used for one Message Processing.

newProvideFlowStepBeginLogData

protected final org.ow2.petals.commons.logger.ProvideFlowStepBeginLogData newProvideFlowStepBeginLogData(org.ow2.petals.component.framework.api.message.Exchange exchange)