Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

merging http://svn.apache.org/viewvc?view=rev&revision=818224 

git-svn-id: https://svn.apache.org/repos/asf/activemq/branches/activemq-5.3@818226 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2009-09-23 19:47:01 +00:00
parent 8715f19d0d
commit 88d5c9c296
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -59,12 +59,16 @@ import org.apache.kahadb.util.*;
public class MessageDatabase {
public static final String PROPERTY_LOG_SLOW_ACCESS_TIME = "org.apache.activemq.store.kahadb.LOG_SLOW_ACCESS_TIME";
public static final int LOG_SLOW_ACCESS_TIME = Integer.parseInt(System.getProperty(PROPERTY_LOG_SLOW_ACCESS_TIME, "500"));
private static final Log LOG = LogFactory.getLog(MessageDatabase.class);
private static final int DATABASE_LOCKED_WAIT_DELAY = 10 * 1000;
public static final int CLOSED_STATE = 1;
public static final int OPEN_STATE = 2;
protected class Metadata {
protected Page<Metadata> page;
protected int state;
@ -566,8 +570,8 @@ public class MessageDatabase {
});
}
long end = System.currentTimeMillis();
if( end-start > 100 ) {
LOG.info("KahaDB Cleanup took "+(end-start));
if( LOG_SLOW_ACCESS_TIME>0 && end-start > LOG_SLOW_ACCESS_TIME) {
LOG.info("Slow KahaDB access: cleanup took "+(end-start));
}
} catch (IOException e) {
e.printStackTrace();
@ -612,8 +616,8 @@ public class MessageDatabase {
long start2 = System.currentTimeMillis();
process(data, location);
long end = System.currentTimeMillis();
if( end-start > 100 ) {
LOG.info("KahaDB long enqueue time: Journal Add Took: "+(start2-start)+" ms, Index Update took "+(end-start2)+" ms");
if( LOG_SLOW_ACCESS_TIME>0 && end-start > LOG_SLOW_ACCESS_TIME) {
LOG.info("Slow KahaDB access: Journal append took: "+(start2-start)+" ms, Index update took "+(end-start2)+" ms");
}
synchronized (indexMutex) {