kieker.analysis.reader
Class RabbitMqReader

java.lang.Object
  kieker.analysis.reader.AbstractMonitoringReader
      kieker.analysis.reader.RabbitMqReader

All Implemented Interfaces:

IMonitoringReader

public class RabbitMqReader
extends AbstractMonitoringReader

This reader is an alternative to the JMS reader. RabbitMQ showed RabbitMQ high performance in experiments.

Author:

matthias

Constructor Summary

RabbitMqReader()
Constructor for RabbitMqReader.

RabbitMqReader(String rmqHostName, String rmqVirtualHost, String rmqExchangeName, String rmqQueueName, String rmqUserName, String rmqRoutingKey, String rmqPassword, int rmqPortNumber)

Method Summary

boolean	init(String initString) Valid key/value pair: jmsProviderUrl=tcp://localhost:3035/ | jmsDestination=queue1
boolean	read() Starts the reader.

Methods inherited from class kieker.analysis.reader.AbstractMonitoringReader

addRecordReceiver

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMqReader

public RabbitMqReader(String rmqHostName,
                      String rmqVirtualHost,
                      String rmqExchangeName,
                      String rmqQueueName,
                      String rmqUserName,
                      String rmqRoutingKey,
                      String rmqPassword,
                      int rmqPortNumber)

Parameters:

rmqHostName -

rmqVirtualHost -

rmqExchangeName -

rmqQueueName -

rmqUserName -

rmqRoutingKey -

rmqPassword -

rmqPortNumber -

RabbitMqReader

public RabbitMqReader()

Constructor for RabbitMqReader. Requires a subsequent call to the init method in order to specify the input directory using the parameters

Method Detail

init

public boolean init(String initString)

Valid key/value pair: jmsProviderUrl=tcp://localhost:3035/ | jmsDestination=queue1

Parameters:

initString - the initialization string

Returns:

true if the initialization was successful; false if an error occurred

read

public boolean read()

Description copied from interface: IMonitoringReader

Starts the reader. This method is intended to be a blocking operation, i.e., it is assumed that reading has finished before this method returns. The method should indicate an error by the return value false.

Returns:

true if reading was successful; false if an error occurred