|
|
## Write your own consumer with multiple input ports
|
|
|
## Write your own consumer with multiple output ports
|
|
|
|
|
|
For example, consider the `InstanceOfFilter` below. It relays the element from its default input port (got from its super class `AbstractConsumerStage`) to its self-declared output port if the element is an instance of the class represented by `type`. The logics is implemented in the `execute()` method.
|
|
|
|
... | ... | |