From c3748a204d3a657324b2e43732cf52f4589ad646 Mon Sep 17 00:00:00 2001
From: David Georg Reichelt <davidgeorg_reichelt@dagere.de>
Date: Mon, 19 Jul 2021 17:17:59 +0200
Subject: [PATCH] Fix receiver and copy receiver jar to required directory

---
 tools/receiver/build.gradle                              | 9 +++++++++
 .../moobench/tools/receiver/ReceiverConfiguration.java   | 5 +++--
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/tools/receiver/build.gradle b/tools/receiver/build.gradle
index b777f15..15a5514 100644
--- a/tools/receiver/build.gradle
+++ b/tools/receiver/build.gradle
@@ -13,3 +13,12 @@ dependencies {
     implementation 'org.slf4j:slf4j-api:1.7.+'
     implementation 'ch.qos.logback:logback-classic:1.2.3'  
 }
+
+jar {
+	doLast {
+		copy {
+		    from jar
+		    into "../../frameworks/Kieker/scripts/receiver/lib/"
+	    }
+	}
+}
diff --git a/tools/receiver/src/main/java/moobench/tools/receiver/ReceiverConfiguration.java b/tools/receiver/src/main/java/moobench/tools/receiver/ReceiverConfiguration.java
index 4fb52f4..0f0636c 100644
--- a/tools/receiver/src/main/java/moobench/tools/receiver/ReceiverConfiguration.java
+++ b/tools/receiver/src/main/java/moobench/tools/receiver/ReceiverConfiguration.java
@@ -1,13 +1,14 @@
 package moobench.tools.receiver;
 
+import kieker.analysis.source.rewriter.NoneTraceMetadataRewriter;
 import kieker.analysis.source.tcp.MultipleConnectionTcpSourceStage;
 import kieker.analysisteetime.plugin.filter.forward.CountingFilter;
 import teetime.framework.Configuration;
 
 public class ReceiverConfiguration extends Configuration {
 
-	public ReceiverConfiguration(int inputPort, int bufferSize) {
-		MultipleConnectionTcpSourceStage source = new MultipleConnectionTcpSourceStage(inputPort, bufferSize, null);
+	public ReceiverConfiguration(final int inputPort, final int bufferSize) {
+		MultipleConnectionTcpSourceStage source = new MultipleConnectionTcpSourceStage(inputPort, bufferSize, new NoneTraceMetadataRewriter());
 		CountingFilter counting = new CountingFilter();
 		
 		connectPorts(source.getOutputPort(), counting.getInputPort());
-- 
GitLab