Mercurial > stress-tester

changeset 582:41c917297b0e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
ReporterDestination
author Devel 1
date Mon, 02 Oct 2017 09:48:09 +0200
parents 618d4bc8e7a1
children a2c21f45a503
files stress-tester/src/main/java/com/passus/st/Main.java stress-tester/src/main/java/com/passus/st/client/http/ReporterFileDestination.java
diffstat 2 files changed, 14 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/Main.java	Mon Oct 02 09:41:54 2017 +0200
+++ b/stress-tester/src/main/java/com/passus/st/Main.java	Mon Oct 02 09:48:09 2017 +0200
@@ -311,10 +311,10 @@
                 }
                 reporterClient.start();
 
-                ReporterRemoteDestination reporterWrapper = new ReporterRemoteDestination(reporterClient);
-                Registry.getInstance().add(ReporterDestination.SERVICE_NAME, reporterWrapper);
-                client.addListener(reporterWrapper);
-                collector.addHandler(reporterWrapper);
+                ReporterRemoteDestination reporterDestination = new ReporterRemoteDestination(reporterClient);
+                Registry.getInstance().add(ReporterDestination.SERVICE_NAME, reporterDestination);
+                client.addListener(reporterDestination);
+                collector.addHandler(reporterDestination);
             }
 
             if (cl.hasOption("ff")) {
--- a/stress-tester/src/main/java/com/passus/st/client/http/ReporterFileDestination.java	Mon Oct 02 09:41:54 2017 +0200
+++ b/stress-tester/src/main/java/com/passus/st/client/http/ReporterFileDestination.java	Mon Oct 02 09:48:09 2017 +0200
@@ -4,10 +4,20 @@
 import com.passus.commons.metric.MetricsCollection;
 import com.passus.net.http.HttpRequest;
 import com.passus.net.http.HttpResponse;
+import java.io.File;
+import java.io.IOException;
 
 
 public class ReporterFileDestination implements ReporterDestination {
 
+    public ReporterFileDestination(String directory) throws IOException {
+        
+    }
+
+    public ReporterFileDestination(File directory) throws IOException {
+        
+    }
+
     @Override
     public void responseReceived(HttpRequest request, HttpResponse response, HttpFlowContext context) {
         throw new UnsupportedOperationException("Not supported yet.");