guarana.toolkit.task.transformers
Class Assembler
java.lang.Object
guarana.util.observer.smart.SmartObservable
guarana.framework.task.Task
guarana.toolkit.task.transformers.Transformer
guarana.toolkit.task.transformers.Assembler
- All Implemented Interfaces:
- ISource, guarana.util.observer.smart.ISmartObserver
public abstract class Assembler
- extends Transformer
Constructs a new outbound message from two or more inbound messages.
The outbound message 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 |
Assembler(String name,
int numberOfInputs)
Constructs a new assembler task. |
Assembler(String name,
int numberOfInputs,
int numberOfOutputs)
Constructs a new assembler 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 |
Assembler
public Assembler(String name,
int numberOfInputs)
- Constructs a new assembler task.
- Parameters:
name
- The name of this task.numberOfInputs
- The number of input.
Assembler
public Assembler(String name,
int numberOfInputs,
int numberOfOutputs)
- Constructs a new assembler 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