Author: rajdavies
Date: Fri Dec 29 12:24:11 2006
New Revision: 491090
URL: http://svn.apache.org/viewvc?view=rev&rev=491090
Log:
clear batch entry if no more messages in the container
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java?view=diff&rev=491090&r1=491089&r2=491090
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
Fri Dec 29 12:24:11 2006
@@ -121,6 +121,9 @@
}
}
}
+ if (messageContainer.isEmpty()) {
+ batchEntry = null;
+ }
}
public synchronized void recover(MessageRecoveryListener listener) throws
Exception{
