@Deprecated public class AMQPReaderStage extends teetime.framework.AbstractProducerStage<IMonitoringRecord>
Constructor and Description |
---|
AMQPReaderStage(java.lang.String uri,
java.lang.String queueName,
int heartbeat)
Deprecated.
Creates a new AMQP reader.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute()
Deprecated.
|
void |
terminateStage()
Deprecated.
Terminates the reader logic by returning from read method and terminates the
execution of the stage.
|
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, toString, workCompleted
public AMQPReaderStage(java.lang.String uri, java.lang.String queueName, int heartbeat)
uri
- The name of the configuration property for the server URI.queueName
- The name of the configuration property for the AMQP queue
name.heartbeat
- The name of the configuration property for the heartbeat
timeout.protected void execute()
execute
in class teetime.framework.AbstractStage
public void terminateStage()
terminateStage
in class teetime.framework.AbstractStage
Copyright 2021 Kieker Project, http://kieker-monitoring.net