kieker.analysis.reader
Class JMSReader

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

All Implemented Interfaces:

IMonitoringLogReader

public class JMSReader
extends AbstractMonitoringLogReader

Reads tpmon messages from a (remote or local) JMS queue and processes them in tpan.

Author:

Andre van Hoorn, Matthias Rohr History 2009-07-01 (AvH) Initial version 2009-07-25 (MR)

Constructor Summary

JMSReader()
Constructor for JMSReader.

JMSReader(String jmsProviderUrl, String jmsDestination)

Method Summary

void	init(String initString) Valid key/value pair: jmsProviderUrl=tcp://localhost:3035/ | jmsDestination=queue1
boolean	read() A call to this method is a blocking call.

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

JMSReader

public JMSReader(String jmsProviderUrl,
                 String jmsDestination)

Parameters:

jmsServerLocation - = for instance "tcp://127.0.0.1:3035/"

jmsDestination - = for instance "queue1"

Throws:

IllegalArgumentException - if passed parameters are null or empty.

JMSReader

public JMSReader()

Constructor for JMSReader. 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

A call to this method is a blocking call.

Returns:

true iff reading was successful

Throws:

MonitoringLogReaderException