Package kieker.analysis.generic.source.amqp

Class AMQPReader

java.lang.Object

kieker.analysis.generic.source.amqp.AMQPReader

public final class AMQPReader
extends Object

Logic module for the reader stage that reads monitoring records from an AMQP queue.

Since:

1.12

Author:

Holger Knoche, Lars Bluemke, Sören Henning

Constructor Summary

Constructors

Constructor	Description
AMQPReader(String uri, String queueName, int heartbeat, Consumer<IMonitoringRecord> elementReceivedCallback)	Creates a new logic module for an AMQP reader.

Method Summary

Modifier and Type	Method	Description
void	deliverRecord(IMonitoringRecord monitoringRecord)
void	init()
boolean	read()
void	terminate()	Terminates the reader logic by returning from read method.

Methods inherited from class java.lang.Object

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

Constructor Details

AMQPReader

public AMQPReader(String uri,
 String queueName,
 int heartbeat,
 Consumer<IMonitoringRecord> elementReceivedCallback)

Creates a new logic module for an 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.

elementReceivedCallback - The actual teetime stage which uses this class.

Method Details

init

public void init()

read

public boolean read()

terminate

public void terminate()

Terminates the reader logic by returning from read method.

deliverRecord

public void deliverRecord(IMonitoringRecord monitoringRecord)