public final class FileExtensionSwitch extends AbstractConsumerStage<File>
inputPort
logger
Constructor and Description |
---|
FileExtensionSwitch() |
Modifier and Type | Method and Description |
---|---|
OutputPort<File> |
addFileExtension(String fileExtension) |
protected void |
execute(File file)
Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
|
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
protected void execute(File file)
AbstractConsumerStage
execute
in class AbstractConsumerStage<File>
file
- the next non-null element from the (only) input port of this stagepublic OutputPort<File> addFileExtension(String fileExtension)
Copyright © 2015–2020. All rights reserved.