[tx-control] Enhance the Coordinator Optimisation test to show one transaction isn't necessarily better
git-svn-id: https://svn.apache.org/repos/asf/aries/trunk/tx-control@1744675 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java b/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
index 3c99b82..acd2102 100644
--- a/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
+++ b/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
@@ -63,6 +63,7 @@
.collect(toList());
long noCoord;
+ long oneTran;
long withCoord;
long start = System.currentTimeMillis();
@@ -75,17 +76,27 @@
txControl.required(() -> connection.createStatement().executeUpdate("DELETE FROM TEST_TABLE"));
+ txControl.required(() -> {
+ messages.stream()
+ .forEach(this::persistMessage);
+ return null;
+ });
+ oneTran = System.currentTimeMillis() - start;
+
+ txControl.required(() -> connection.createStatement().executeUpdate("DELETE FROM TEST_TABLE"));
+
coordinator.begin("foo", MINUTES.toMillis(5));
start = System.currentTimeMillis();
try {
messages.stream()
- .forEach(this::persistMessage);
+ .forEach(this::persistMessage);
} finally {
coordinator.peek().end();
withCoord = System.currentTimeMillis() - start;
}
- System.out.println("\n\n\n\nWithout Coord: " + noCoord + " With Coord: " + withCoord);
+ System.out.println("\n\n\n\nWithout Coord: " + noCoord + " One Tran: " + oneTran+
+ " With Coord: " + withCoord);
}
@SuppressWarnings("unchecked")
