<commit_before>package tools.descartes.petsupplystore.kieker.rabbitmq;

import java.io.PrintWriter;
import java.io.StringWriter;

import kieker.analysis.AnalysisController;
import kieker.analysis.IAnalysisController;
import kieker.analysis.exception.AnalysisConfigurationException;
import kieker.analysis.plugin.reader.amqp.AmqpReader;
import kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader;
import kieker.analysis.plugin.reader.newio.RawDataReaderPlugin;
import kieker.common.configuration.Configuration;

public class LogReaderDaemon implements Runnable {

	private static final String URI = "amqp://admin:nimda@127.0.0.1";
	private static final String QUEUENAME = "kieker";

	@Override
	public void run() {
		final IAnalysisController analysisInstance = new AnalysisController();
		Configuration configuration = new Configuration();

		configuration.setProperty(RawDataReaderPlugin.CONFIG_PROPERTY_READER, "kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader");
		configuration.setProperty(RawDataReaderPlugin.CONFIG_PROPERTY_DESERIALIZER, "kieker.analysis.plugin.reader.newio.deserializer.BinaryDeserializer");

		configuration.setProperty(ChunkingAmqpReader.CONFIG_PROPERTY_URI, URI);
		configuration.setProperty(ChunkingAmqpReader.CONFIG_PROPERTY_QUEUENAME, QUEUENAME);

		RawDataReaderPlugin reader = new RawDataReaderPlugin(configuration, analysisInstance);
        final LogConsumer consumer = new LogConsumer(new Configuration(), analysisInstance);
 
        try {
            analysisInstance.connect(reader, AmqpReader.OUTPUT_PORT_NAME_RECORDS, consumer,
                    LogConsumer.INPUT_PORT_NAME);
            analysisInstance.run();
        } catch (final AnalysisConfigurationException e) {
            final StringWriter sw = new StringWriter();
            final PrintWriter pw = new PrintWriter(sw);
            e.printStackTrace(pw);
            final String sStackTrace = sw.toString();
            throw new IllegalStateException(sStackTrace);
        }
	}

}<commit_msg>added heartbeat to avoid warning<commit_after>package tools.descartes.petsupplystore.kieker.rabbitmq;

import java.io.PrintWriter;
import java.io.StringWriter;

import kieker.analysis.AnalysisController;
import kieker.analysis.IAnalysisController;
import kieker.analysis.exception.AnalysisConfigurationException;
import kieker.analysis.plugin.reader.amqp.AmqpReader;
import kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader;
import kieker.analysis.plugin.reader.newio.RawDataReaderPlugin;
import kieker.common.configuration.Configuration;

public class LogReaderDaemon implements Runnable {

	private static final String URI = "amqp://admin:nimda@127.0.0.1";
	private static final String QUEUENAME = "kieker";

	@Override
	public void run() {
		final IAnalysisController analysisInstance = new AnalysisController();
		Configuration configuration = new Configuration();

		configuration.setProperty(RawDataReaderPlugin.CONFIG_PROPERTY_READER, "kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader");
		configuration.setProperty(RawDataReaderPlugin.CONFIG_PROPERTY_DESERIALIZER, "kieker.analysis.plugin.reader.newio.deserializer.BinaryDeserializer");

		configuration.setProperty(ChunkingAmqpReader.CONFIG_PROPERTY_URI, URI);
		configuration.setProperty(ChunkingAmqpReader.CONFIG_PROPERTY_HEARTBEAT, 0);
		configuration.setProperty(ChunkingAmqpReader.CONFIG_PROPERTY_QUEUENAME, QUEUENAME);

		RawDataReaderPlugin reader = new RawDataReaderPlugin(configuration, analysisInstance);
        final LogConsumer consumer = new LogConsumer(new Configuration(), analysisInstance);
 
        try {
            analysisInstance.connect(reader, AmqpReader.OUTPUT_PORT_NAME_RECORDS, consumer,
                    LogConsumer.INPUT_PORT_NAME);
            analysisInstance.run();
        } catch (final AnalysisConfigurationException e) {
            final StringWriter sw = new StringWriter();
            final PrintWriter pw = new PrintWriter(sw);
            e.printStackTrace(pw);
            final String sStackTrace = sw.toString();
            throw new IllegalStateException(sStackTrace);
        }
	}

}
{'fraction_non_alphanumeric': 0.08274519347773181, 'fraction_numerical': 0.003163786809442687, 'mean_word_length': 4.896700143472023, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 2, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2899607', 'n_tokens_mistral': 1134, 'n_tokens_neox': 1088, 'n_words': 202}