guarana.toolkit.task.transformers
Class CrossBuilder
java.lang.Object
guarana.util.observer.smart.SmartObservable
guarana.framework.task.Task
guarana.toolkit.task.transformers.Transformer
guarana.toolkit.task.transformers.CrossBuilder
- All Implemented Interfaces:
- ISource, guarana.util.observer.smart.ISmartObserver
public abstract class CrossBuilder
- extends Transformer
Takes two or more inbound messages and builds several new outbound messages
where each outbound message represents one possible combination of values inside the inbound messages.
The outbound messages must have a new MESSAGE_ID and the inbound messages as parents.
Graphical notation:
This is an Integration Pattern implementation
Problem:
Solution:
Details:
- Number of Inputs: n
- Number of Outputs: 1
- Outbound message is built with a new Java Object!
- Since:
- Guaranį SDK 1.3.0
- Author:
- Rafael Z. Frantz
Constructor Summary |
CrossBuilder(String name,
int numberOfInputs)
Constructs a new cross builder task. |
CrossBuilder(String name,
int numberOfInputs,
int numberOfOutputs)
Constructs a new cross builder task. |
Method Summary |
abstract void |
doWork(Exchange exchange)
This method implements the business logic of this task. |
Methods inherited from class guarana.util.observer.smart.SmartObservable |
addSmartObserver, containsSmartObserver, containsSmartObserver, countSmartObservers, deleteSmartObserver, deleteSmartObservers, hasChanged, notifySmartObservers, notifySmartObservers |
CrossBuilder
public CrossBuilder(String name,
int numberOfInputs)
- Constructs a new cross builder task.
- Parameters:
name
- The name of this task.numberOfInputs
- The number of input.
CrossBuilder
public CrossBuilder(String name,
int numberOfInputs,
int numberOfOutputs)
- Constructs a new cross builder task.
- Parameters:
name
- The name of this task.numberOfInputs
- The number of input gateways this task must have.numberOfOutputs
- The number of output gateways this task must have.
doWork
public abstract void doWork(Exchange exchange)
throws TaskExecutionException
- This method implements the business logic of this task.
Assembles a set of messages into just one message.
- Overrides:
doWork
in class Task
- Parameters:
exchange
- An exchange object that holds the inbound messages of this task.
- Throws:
TaskExecutionException
- to report any exception that has occurred during the execution of this method.
Guaranį DSL Home