git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1381980 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2012-09-07 11:23:05 +00:00
parent a00f235842
commit 97f03d43dd
2 changed files with 2 additions and 2 deletions

View File

@ -36,7 +36,7 @@ public class JDBCIOExceptionHandler extends DefaultIOExceptionHandler {
boolean hasLock = true;
if (broker.getPersistenceAdapter() instanceof JDBCPersistenceAdapter) {
JDBCPersistenceAdapter jdbcPersistenceAdapter = (JDBCPersistenceAdapter) broker.getPersistenceAdapter();
Locker locker = jdbcPersistenceAdapter.getDatabaseLocker();
Locker locker = jdbcPersistenceAdapter.getLocker();
if (locker != null) {
try {
if (!locker.keepAlive()) {

View File

@ -301,7 +301,7 @@ public class JDBCPersistenceAdapter extends DataSourceSupport implements Persist
}
if (isUseDatabaseLock()) {
Locker service = getDatabaseLocker();
Locker service = getLocker();
if (service == null) {
LOG.warn("No databaseLocker configured for the JDBC Persistence Adapter");
} else {