You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2008/02/20 23:05:05 UTC
svn commit: r629631 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java
Author: chirino
Date: Wed Feb 20 14:05:02 2008
New Revision: 629631
URL: http://svn.apache.org/viewvc?rev=629631&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-1591
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java?rev=629631&r1=629630&r2=629631&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java Wed Feb 20 14:05:02 2008
@@ -77,7 +77,7 @@
private int cleanupPeriod = 1000 * 60 * 5;
private boolean useExternalMessageReferences;
private boolean useDatabaseLock = true;
- private int lockKeepAlivePeriod;
+ private long lockKeepAlivePeriod = 1000*30;
private DatabaseLocker databaseLocker;
private boolean createTablesOnStartup = true;
@@ -496,5 +496,13 @@
public long size(){
return 0;
+ }
+
+ public int getLockKeepAlivePeriod() {
+ return lockKeepAlivePeriod;
+ }
+
+ public void setLockKeepAlivePeriod(int lockKeepAlivePeriod) {
+ this.lockKeepAlivePeriod = lockKeepAlivePeriod;
}
}