diff --git a/tools/receiver/build.gradle b/tools/receiver/build.gradle index b777f15fea4f4a731d1b4d35dfc830ab4eb54e20..15a5514a6ffc4fb25dc6e7fd42855df9f2dac28a 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 4fb52f4d89615768f6cbbff9fc71f0daa044bf31..0f0636cb51da079b18e6d9397652721a726778e9 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());