Added a large stubs GET scenario

Author: tomakehurst

.ruby-version

@@ -0,0 +1 @@
+2.1.10

perf-test/src/gatling/scala/wiremock/StubbingAndVerifyingSimulation.scala

@@ -14,7 +14,8 @@ class StubbingAndVerifyingSimulation extends Simulation {
   before {
     loadTestConfiguration.before()
 //    loadTestConfiguration.mixed100StubScenario()
-    loadTestConfiguration.onlyGet6000StubScenario()
+//    loadTestConfiguration.onlyGet6000StubScenario()
+    loadTestConfiguration.getLargeStubScenario()
   }
 
   after {
@@ -80,9 +81,20 @@ class StubbingAndVerifyingSimulation extends Simulation {
       }
   }
 
+  val getLargeStubsScenario = {
+    scenario("100 large GETs")
+      .repeat(1) {
+        exec(http("GETs")
+          .get(session => s"load-test/${random.nextInt(99) + 1}")
+          .header("Accept", "text/plain+stuff")
+          .check(status.is(200)))
+      }
+  }
+
   setUp(
 //    mixed100StubScenario.inject(constantUsersPerSec(loadTestConfiguration.getRate) during(loadTestConfiguration.getDurationSeconds seconds))
-    onlyGet6000StubScenario.inject(constantUsersPerSec(loadTestConfiguration.getRate) during(loadTestConfiguration.getDurationSeconds seconds))
+//    onlyGet6000StubScenario.inject(constantUsersPerSec(loadTestConfiguration.getRate) during(loadTestConfiguration.getDurationSeconds seconds))
+    getLargeStubsScenario.inject(constantUsersPerSec(loadTestConfiguration.getRate) during(loadTestConfiguration.getDurationSeconds seconds))
   ).protocols(httpConf)
 
 }

perf-test/src/main/java/wiremock/LoadTestConfiguration.java

@@ -80,7 +80,7 @@ public void before() {
     }
 
     public void onlyGet6000StubScenario() {
-        System.out.println("Regsitering stubs");
+        System.out.println("Registering stubs");
 
         ExecutorService executorService = Executors.newFixedThreadPool(100);
 
@@ -117,6 +117,44 @@ public void run() {
         executorService.shutdown();
     }
 
+    public void getLargeStubScenario() {
+        System.out.println("Registering stubs");
+
+        ExecutorService executorService = Executors.newFixedThreadPool(10);
+
+        wm.register(any(anyUrl()).atPriority(10)
+                .willReturn(notFound())
+        );
+
+        List<Future<?>> futures = new ArrayList<>();
+        for (int i = 1; i <= 100; i++) {
+            final int count = i;
+            futures.add(executorService.submit(new Runnable() {
+                @Override
+                public void run() {
+                    wm.register(get("/load-test/" + count)
+                            .willReturn(ok(randomAscii(50000, 90000))));
+
+                    if (count % 100 == 0) {
+                        System.out.print(count + " ");
+                    }
+
+                }
+            }));
+
+        }
+
+        for (Future<?> future: futures) {
+            try {
+                future.get(30, SECONDS);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        executorService.shutdown();
+    }
+
     public void mixed100StubScenario() {
         // TODO: Optionally add delay
         wm.setGlobalRandomDelayVariable(new UniformDistribution(100, 2000));