public class Clock extends AbstractProducerStage<Long>
intervalDelayInMs.
+------------------------+
| |
| +---+
| *INTERVAL* +--> | |
| +---+
| |
+------------------------+
outputPortlogger| Constructor and Description |
|---|
Clock()
Deprecated.
since 3.0. Use
Clock(TerminationCondition) instead. |
Clock(TerminationCondition terminationCondition) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
execute()
Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
|
long |
getInitialDelayInMs() |
long |
getIntervalDelayInMs() |
void |
setInitialDelayInMs(long initialDelayInMs) |
void |
setIntervalDelayInMs(long intervalDelayInMs) |
getOutputPort, getTerminationStrategyabort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted@Deprecated public Clock()
Clock(TerminationCondition) instead.public Clock(TerminationCondition terminationCondition)
protected void execute()
AbstractStageexecute in class AbstractStagepublic long getInitialDelayInMs()
public void setInitialDelayInMs(long initialDelayInMs)
public long getIntervalDelayInMs()
public void setIntervalDelayInMs(long intervalDelayInMs)
Copyright © 2015–2020. All rights reserved.