diff --git a/sdks/java/graalvm-smoke/src/main/java/org/byteveda/taskito/graalvm/Smoke.java b/sdks/java/graalvm-smoke/src/main/java/org/byteveda/taskito/graalvm/Smoke.java index 444ab510..e47969f2 100644 --- a/sdks/java/graalvm-smoke/src/main/java/org/byteveda/taskito/graalvm/Smoke.java +++ b/sdks/java/graalvm-smoke/src/main/java/org/byteveda/taskito/graalvm/Smoke.java @@ -31,10 +31,11 @@ public static void main(String[] args) throws Exception { String id = queue.enqueue(echo, "graalvm"); CountDownLatch done = new CountDownLatch(1); - try (Worker worker = queue.worker() + Worker worker = queue.worker() .handle(echo, (String payload) -> payload.length()) .on(EventName.SUCCESS, event -> done.countDown()) - .start()) { + .start(); + try (worker) { if (!done.await(20, TimeUnit.SECONDS)) { throw new IllegalStateException("task did not complete"); }