Kieker 1.2

kieker.analysis.reader
Class RabbitMqReader

java.lang.Object
  extended by kieker.analysis.reader.AbstractMonitoringLogReader
      extended by 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

Kieker 1.2

Copyright 2010 the Kieker Project, http://kieker.sourceforge.net