org.apache.servicemix.eip.patterns
Class Pipeline

java.lang.Object
  org.apache.servicemix.common.endpoints.AbstractEndpoint
      org.apache.servicemix.common.endpoints.SimpleEndpoint
          org.apache.servicemix.common.endpoints.ProviderEndpoint
              org.apache.servicemix.eip.EIPEndpoint
                  org.apache.servicemix.eip.patterns.Pipeline

All Implemented Interfaces:

org.apache.servicemix.common.Endpoint

public class Pipeline
extends EIPEndpoint

The Pipeline component is a bridge between an In-Only (or Robust-In-Only) MEP and an In-Out MEP. When the Pipeline receives an In-Only MEP, it will send the input in an In-Out MEP to the tranformer destination and forward the response in an In-Only MEP to the target destination. In addition, this component is fully asynchronous and uses an exchange store to provide full HA and recovery for clustered / persistent flows.

Version:

$Revision: 376451 $

Author:

gnodet

Field Summary

Fields inherited from class org.apache.servicemix.eip.EIPEndpoint

lockManager, store, storeFactory, timerManager, wsdlExchangeTarget, wsdlResource

Fields inherited from class org.apache.servicemix.common.endpoints.AbstractEndpoint

definition, description, endpoint, interfaceName, logger, service, serviceUnit

Constructor Summary

Pipeline()

Method Summary

protected javax.wsdl.Definition	getDefinitionFromWsdlExchangeTarget()
ExchangeTarget	getFaultsTarget()
ExchangeTarget	getTarget()
ExchangeTarget	getTransformer()
boolean	isCopyAttachments()
boolean	isCopyProperties()
boolean	isSendFaultsToTarget()
protected void	processAsync(javax.jbi.messaging.MessageExchange exchange)
protected void	processSync(javax.jbi.messaging.MessageExchange exchange)
void	setCopyAttachments(boolean copyAttachments)
void	setCopyProperties(boolean copyProperties)
void	setFaultsTarget(ExchangeTarget faultsTarget)
void	setSendFaultsToTarget(boolean sendFaultsToTarget)
void	setTarget(ExchangeTarget target)
void	setTransformer(ExchangeTarget transformer)
void	validate()

Methods inherited from class org.apache.servicemix.eip.EIPEndpoint

chooseFirstEndpointWithDescriptor, copyAttachments, copyProperties, getDefinition, getDefinitionFromDescription, getDefinitionFromWsdlResource, getDescription, getDescriptionForExchangeTarget, getEndpointsForExchangeTarget, getLockManager, getStore, getStoreFactory, getTimerManager, getWsdlExchangeTarget, getWsdlResource, process, setLockManager, setStore, setStoreFactory, setTimerManager, setWsdlExchangeTarget, setWsdlResource, start, stop

Methods inherited from class org.apache.servicemix.common.endpoints.ProviderEndpoint

activate, deactivate, getRole, processInOnly, processInOut

Methods inherited from class org.apache.servicemix.common.endpoints.SimpleEndpoint

done, fail, getChannel, getContext, getExchangeFactory, send, sendSync

Methods inherited from class org.apache.servicemix.common.endpoints.AbstractEndpoint

getEndpoint, getInterfaceName, getKey, getService, getServiceUnit, isExchangeOkay, prepareExchange, setDefinition, setDescription, setEndpoint, setInterfaceName, setService, setServiceUnit, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Pipeline

public Pipeline()

Method Detail

getTarget

public ExchangeTarget getTarget()

Returns:

Returns the target.

setTarget

public void setTarget(ExchangeTarget target)

Parameters:

target - The target to set.

getFaultsTarget

public ExchangeTarget getFaultsTarget()

Returns:

the faultsTarget

setFaultsTarget

public void setFaultsTarget(ExchangeTarget faultsTarget)

Parameters:

faultsTarget - the faultsTarget to set

isSendFaultsToTarget

public boolean isSendFaultsToTarget()

Returns:

the sendFaultsToTarget

setSendFaultsToTarget

public void setSendFaultsToTarget(boolean sendFaultsToTarget)

Parameters:

sendFaultsToTarget - the sendFaultsToTarget to set

getTransformer

public ExchangeTarget getTransformer()

Returns:

Returns the transformer.

setTransformer

public void setTransformer(ExchangeTarget transformer)

Parameters:

transformer - The transformer to set.

isCopyProperties

public boolean isCopyProperties()

setCopyProperties

public void setCopyProperties(boolean copyProperties)

isCopyAttachments

public boolean isCopyAttachments()

setCopyAttachments

public void setCopyAttachments(boolean copyAttachments)

validate

public void validate()
              throws javax.jbi.management.DeploymentException

Specified by:

validate in interface org.apache.servicemix.common.Endpoint

Overrides:

validate in class org.apache.servicemix.common.endpoints.AbstractEndpoint

Throws:

javax.jbi.management.DeploymentException

processSync

protected void processSync(javax.jbi.messaging.MessageExchange exchange)
                    throws Exception

Specified by:

processSync in class EIPEndpoint

Throws:

Exception

processAsync

protected void processAsync(javax.jbi.messaging.MessageExchange exchange)
                     throws Exception

Specified by:

processAsync in class EIPEndpoint

Throws:

Exception

getDefinitionFromWsdlExchangeTarget

protected javax.wsdl.Definition getDefinitionFromWsdlExchangeTarget()

Overrides:

getDefinitionFromWsdlExchangeTarget in class EIPEndpoint