diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java index c193c46fca..7389aef5c0 100644 --- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java +++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java @@ -686,7 +686,7 @@ public class JDBCPersistenceAdapter extends DataSourceServiceSupport implements throw new IOException("isValid(10) failed for: " + connection); } } catch (SQLException e) { - LOG.debug("Could not get JDBC connection for checkpoint: " + e); + LOG.debug("Could not get JDBC connection for checkpoint: " + e, e); throw IOExceptionSupport.create(e); } finally { if (connection != null) { diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveTest.java index f2b176d5e5..61a7fc8119 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveTest.java @@ -45,6 +45,7 @@ public class DbRestartJDBCQueueMasterSlaveTest extends JDBCQueueMasterSlaveTest LOG.info("STOPPING DB!@!!!!"); final EmbeddedDataSource ds = ((SyncCreateDataSource)getExistingDataSource()).getDelegate(); ds.setShutdownDatabase("shutdown"); + ds.setCreateDatabase("not_any_more"); LOG.info("DB STOPPED!@!!!!"); Thread dbRestartThread = new Thread("db-re-start-thread") { diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueTest.java index 6064efb666..ab586cff58 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueTest.java @@ -106,6 +106,7 @@ public class DbRestartJDBCQueueTest extends JmsTopicSendReceiveWithTwoConnection LOG.info("STOPPING DB!@!!!!"); final EmbeddedDataSource ds = sharedDs; ds.setShutdownDatabase("shutdown"); + ds.setCreateDatabase("not_any_more"); try { ds.getConnection(); } catch (Exception ignored) {