Mercurial > stress-tester

changeset 564:911a02356a4b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reporter - endOfReplay
author Devel 1
date Thu, 21 Sep 2017 16:12:00 +0200
parents 0f92cca7980c
children 65c26bb5ca38
files stress-tester/src/main/java/com/passus/st/Main.java
diffstat 1 files changed, 3 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/Main.java	Thu Sep 21 15:41:50 2017 +0200
+++ b/stress-tester/src/main/java/com/passus/st/Main.java	Thu Sep 21 16:12:00 2017 +0200
@@ -1,6 +1,7 @@
 package com.passus.st;
 
 import com.passus.commons.ConversionException;
+import com.passus.commons.metric.MapMetric;
 import com.passus.commons.metric.Metric;
 import com.passus.commons.service.Registry;
 import com.passus.config.Configuration;
@@ -36,6 +37,7 @@
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ -422,6 +424,7 @@
             client.stop();
             emitter.stop();
             if (reporterClient != null) {
+                reporterClient.send(new MapMetric("endOfReplay", Collections.emptyMap()));
                 reporterClient.waitForEmptyQueue();
                 reporterClient.stop();
                 System.out.println("Dropped reporter messages: " + reporterClient.getDroppedMessages());