Skip to content
Snippets Groups Projects
Commit 45c528cd authored by Lars Erik Blümke's avatar Lars Erik Blümke
Browse files

new class for actual teetime producer stage

parent 59214fb6
No related branches found
No related tags found
No related merge requests found
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();
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment