diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java index c18ddae4d2..f8b8c10356 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java @@ -542,6 +542,7 @@ public class DefaultJDBCAdapter implements JDBCAdapter { public void doDeleteOldMessages(TransactionContext c) throws SQLException, IOException { PreparedStatement s = null; try { + log.debug("Executing SQL: "+statements.getDeleteOldMessagesStatement()); s = c.getConnection().prepareStatement(statements.getDeleteOldMessagesStatement()); s.setLong(1, System.currentTimeMillis()); int i = s.executeUpdate();