T
- The type of the list.public class ListCollectionFilter<T>
extends teetime.framework.AbstractConsumerStage<T>
Modifier and Type | Class and Description |
---|---|
static class |
ListCollectionFilter.ListFullBehavior
An enum for all possible list full behaviors.
|
Constructor and Description |
---|
ListCollectionFilter(int maxNumberOfEntries,
ListCollectionFilter.ListFullBehavior listFullBehavior)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clears the list.
|
protected void |
execute(T data)
This method represents the input port.
|
java.util.List<T> |
getList()
Delivers a copy of the internal list.
|
teetime.framework.OutputPort<T> |
getOutputPort() |
int |
size() |
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
public ListCollectionFilter(int maxNumberOfEntries, ListCollectionFilter.ListFullBehavior listFullBehavior)
maxNumberOfEntries
- max number of entries to be stored in list (-1 for unlimited)listFullBehavior
- behavior when list is fullprotected void execute(T data) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<T>
data
- The next element.java.lang.Exception
public teetime.framework.OutputPort<T> getOutputPort()
public void clear()
public java.util.List<T> getList()
public int size()
Copyright 2021 Kieker Project, http://kieker-monitoring.net