org.apache.camel.processor
Class Pipeline
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.processor.MulticastProcessor
org.apache.camel.processor.Pipeline
- All Implemented Interfaces:
- Processor, Service
public class Pipeline
- extends MulticastProcessor
- implements Processor
Creates a Pipeline pattern where the output of the previous step is sent as input to the next step when working
with request/response message exchanges.
- Version:
- $Revision: 534145 $
Pipeline
public Pipeline(Collection<Endpoint> endpoints)
throws Exception
- Throws:
Exception
process
public void process(Exchange exchange)
throws Exception
- Description copied from interface:
Processor
- Processes the message exchange
- Specified by:
process
in interface Processor
- Overrides:
process
in class MulticastProcessor
- Throws:
Exception
- if an internal processing error has occurred.
createNextExchange
protected Exchange createNextExchange(Producer producer,
Exchange previousExchange)
- Strategy method to create the next exchange from the
- Parameters:
producer
- the producer used to send to the endpointpreviousExchange
- the previous exchange
- Returns:
- a new exchange
copyExchangeStrategy
protected Exchange copyExchangeStrategy(Exchange exchange)
- Strategy method to copy the exchange before sending to another endpoint. Derived classes such as the
Pipeline
will not clone the exchange
- Parameters:
exchange
-
- Returns:
- the current exchange if no copying is required such as for a pipeline otherwise a new copy of the exchange is returned.
toString
public String toString()
- Overrides:
toString
in class MulticastProcessor
Copyright © 2007 Apache Software Foundation. All Rights Reserved.