public class JMSReaderStage extends teetime.framework.AbstractProducerStage<IMonitoringRecord>
Constructor and Description |
---|
JMSReaderStage(java.lang.String jmsProviderUrl,
java.lang.String jmsDestination,
java.lang.String jmsFactoryLookupName)
Creates a new JMSReader.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute() |
protected void |
workCompleted()
Terminates the reader logic in addition to the following.
|
getOutputPort, getTerminationStrategy
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
public JMSReaderStage(java.lang.String jmsProviderUrl, java.lang.String jmsDestination, java.lang.String jmsFactoryLookupName) throws AnalysisConfigurationException
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
.AnalysisConfigurationException
- on errors when configuring the JMSReaderCopyright 2021 Kieker Project, http://kieker-monitoring.net