kieker.analysis.reader
Class RabbitMqReader

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

All Implemented Interfaces:

IMonitoringLogReader

public class RabbitMqReader
extends AbstractMonitoringLogReader

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

void	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.AbstractMonitoringLogReader

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 void init(String initString)
          throws IllegalArgumentException

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

Parameters:

initString - the initialization string

Throws:

IllegalArgumentException - if an error occured

read

public boolean read()
             throws MonitoringLogReaderException

Description copied from interface: IMonitoringLogReader

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.

Returns:

true iff reading was successful

Throws:

MonitoringLogReaderException