From 45c528cd487f7e31f74ca5afec57fb6dddaebef2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lars=20Blu=CC=88mke?= <lbl@informatik.uni-kiel.de>
Date: Thu, 28 Apr 2016 15:06:52 +0200
Subject: [PATCH] new class for actual teetime producer stage
---
.../analysis/plugin/reader/jms/JMSReader.java | 25 +++++++++++++++++++
1 file changed, 25 insertions(+)
create mode 100644 src/main/java/kieker/analysis/plugin/reader/jms/JMSReader.java
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 00000000..dc07b879
--- /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();
+ }
+
+}
--
GitLab