Package kieker.analysis.generic.source.jms

Class JMSReaderStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysis.generic.source.jms.JMSReaderStage

public class JMSReaderStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>

Reads monitoring records from a (remote or local) JMS queue by using the read-method from JMSReaderLogicModule. JMSReaderLogicModule also delivers read records to the output port.

Since:

0.95a

Author:

Andre van Hoorn, Matthias Rohr, Lars Bluemke

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor	Description
JMSReaderStage(String jmsProviderUrl, String jmsDestination, String jmsFactoryLookupName)	Creates a new JMSReader.

Method Summary

Modifier and Type	Method	Description
protected void	execute()
protected void	workCompleted()	Terminates the reader logic in addition to the following.

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString

Methods inherited from class java.lang.Object

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

Constructor Details

JMSReaderStage

public JMSReaderStage(String jmsProviderUrl,
 String jmsDestination,
 String jmsFactoryLookupName)
               throws AnalysisConfigurationException

Creates a new JMSReader.

Parameters:

jmsProviderUrl - The name of the configuration determining the JMS provider URL, e.g. tcp://localhost:3035/

jmsDestination - The name of the configuration determining the JMS destination, e.g. queue1.

jmsFactoryLookupName - The name of the configuration determining the name of the used JMS factory, e.g. org.exolab.jms.jndi.InitialContextFactory.

Throws:

AnalysisConfigurationException - on errors when configuring the JMSReader

Method Details

execute

protected void execute()

Specified by:

execute in class teetime.framework.AbstractStage

workCompleted

protected void workCompleted()

Terminates the reader logic in addition to the following.

Overrides:

workCompleted in class teetime.framework.AbstractStage