public class Clock extends AbstractProducerStage<Long>
intervalDelayInMs
.+------------------------+ | | | +---+ | *INTERVAL* +--> | | | +---+ | | +------------------------+
outputPort
logger
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, getTerminationStrategy
abort, 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()
AbstractStage
execute
in class AbstractStage
public long getInitialDelayInMs()
public void setInitialDelayInMs(long initialDelayInMs)
public long getIntervalDelayInMs()
public void setIntervalDelayInMs(long intervalDelayInMs)
Copyright © 2015–2020. All rights reserved.