diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jdbc/store/journal/JDBCJournalTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jdbc/store/journal/JDBCJournalTest.java index 74031516d2..f73ed4650d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jdbc/store/journal/JDBCJournalTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jdbc/store/journal/JDBCJournalTest.java @@ -88,7 +88,8 @@ public class JDBCJournalTest extends ActiveMQTestBase { System.clearProperty("derby.connection.requireAuthentication"); System.clearProperty("derby.user." + getJdbcUser()); } - scheduledExecutorService.shutdown(); + scheduledExecutorService.shutdownNow(); + scheduledExecutorService.awaitTermination(5, TimeUnit.SECONDS); scheduledExecutorService = null; executorService.shutdown(); executorService = null;