kieker.analysisteetime.plugin.reader.amqp

Class AMQPReaderStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.amqp.AMQPReaderStage

public class AMQPReaderStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>

Reader stage that reads monitoring records from an AMQP queue.

Since:

1.12

Author:

Holger Knoche, Lars Bluemke, Sören Henning

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
AMQPReaderStage(java.lang.String uri, java.lang.String queueName, int heartbeat) Creates a new AMQP reader.

Method Summary

Modifier and Type	Method and Description
protected void	execute()
void	terminateStage() Terminates the reader logic by returning from read method and terminates the execution of the stage.

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AMQPReaderStage

public AMQPReaderStage(java.lang.String uri,
                       java.lang.String queueName,
                       int heartbeat)

Creates a new AMQP reader.

Parameters:

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.

Method Detail

execute

protected void execute()

Specified by:

execute in class teetime.framework.AbstractStage

terminateStage

public void terminateStage()

Terminates the reader logic by returning from read method and terminates the execution of the stage.

Overrides:

terminateStage in class teetime.framework.AbstractStage