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​(java.lang.String jmsProviderUrl, java.lang.String jmsDestination, java.lang.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​(java.lang.String jmsProviderUrl, java.lang.String jmsDestination, java.lang.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