public final class InstanceCounter<T,C extends T> extends AbstractFilter<T>
outputPort
inputPort
logger
Constructor and Description |
---|
InstanceCounter(Class<C> type) |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(T element)
Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
|
int |
getCounter() |
getOutputPort
createInputPort, execute, getInputPort
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getInputPort
protected void execute(T element)
AbstractConsumerStage
execute
in class AbstractConsumerStage<T>
element
- the next non-null element from the (only) input port of this stagepublic int getCounter()
Copyright © 2015–2020. All rights reserved.