--- a/test/jdk/jdk/jfr/api/consumer/streaming/TestJVMExit.java Mon Nov 25 12:34:43 2019 +0100
+++ b/test/jdk/jdk/jfr/api/consumer/streaming/TestJVMExit.java Mon Nov 25 14:06:13 2019 +0100
@@ -42,17 +42,18 @@
public class TestJVMExit {
public static void main(String... args) throws Exception {
- TestProcess process = new TestProcess("exit-application");
- AtomicInteger eventCounter = new AtomicInteger();
- try (EventStream es = EventStream.openRepository(process.getRepository())) {
- // Start from first event in repository
- es.setStartTime(Instant.EPOCH);
- es.onEvent(e -> {
- if (eventCounter.incrementAndGet() == TestProcess.NUMBER_OF_EVENTS) {
- process.exit();
- }
- });
- es.start();
+ try (TestProcess process = new TestProcess("exit-application")) {
+ AtomicInteger eventCounter = new AtomicInteger();
+ try (EventStream es = EventStream.openRepository(process.getRepository())) {
+ // Start from first event in repository
+ es.setStartTime(Instant.EPOCH);
+ es.onEvent(e -> {
+ if (eventCounter.incrementAndGet() == TestProcess.NUMBER_OF_EVENTS) {
+ process.exit();
+ }
+ });
+ es.start();
+ }
}
}
}