diff --git a/src/main/java/kieker/analysis/plugin/reader/jms/JMSReader.java b/src/main/java/kieker/analysis/plugin/reader/jms/JMSReader.java new file mode 100644 index 0000000000000000000000000000000000000000..dc07b8790ea78e9d387b3b8fae5eaf83c5286661 --- /dev/null +++ b/src/main/java/kieker/analysis/plugin/reader/jms/JMSReader.java @@ -0,0 +1,25 @@ +package kieker.analysis.plugin.reader.jms; + +import kieker.common.logging.Log; + +import teetime.framework.AbstractProducerStage; + +/** + * Reads monitoring records from a (remote or local) JMS queue. + * + * @author Lars Erik Bluemke + */ +public class JMSReader extends AbstractProducerStage<Object> { + + private final JMSReaderLogicModule logicModule; + + public JMSReader(final String jmsProviderUrl, final String jmsDestination, final String jmsFactoryLookupName, final Log log) { + this.logicModule = new JMSReaderLogicModule(jmsProviderUrl, jmsDestination, jmsFactoryLookupName, log, this); + } + + @Override + protected void execute() { + logicModule.read(); + } + +}