conf

MichaelBosello · Jun 5, 2018 · f6ba15f · f6ba15f
1 parent 9e3625d
commit f6ba15f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/main/resources/min-remote.conf b/src/main/resources/min-remote.conf
@@ -1,6 +1,9 @@
 akka {
   actor {
     provider = remote
+    default-dispatcher {
+      throughput = 1
+    }
   }
   remote {
     enabled-transports = ["akka.remote.netty.tcp"]

diff --git a/src/test/java/TalkerMain.java b/src/test/java/TalkerMain.java
@@ -14,7 +14,7 @@
 
 public class TalkerMain{
 
-    private final static int N_MESSAGE = 1000;
+    private final static int N_MESSAGE = 200;
 
     public static void main(String[] args) throws InterruptedException {
         System.out.println("talker process started");
@@ -28,7 +28,7 @@ public static void main(String[] args) throws InterruptedException {
         sleep(20000);
         for(int i = 0; i < N_MESSAGE; i++) {
             client.tell(new SendMessage("User" + id + ": message" + i), null);
-            sleep(20);
+            sleep(200);
         }
     }
 }