Fix for the testQueuePersistentUncommitedAcksLostOnRestart() test in RecoveryBrokerTest. Since this test resuses the memory based store instance across restarts, the cusror pointers were not getting reset after restart.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564685 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2007-08-10 17:18:14 +00:00
parent ecf89a60bf
commit 5719351cb7
1 changed files with 1 additions and 0 deletions

View File

@ -56,6 +56,7 @@ class QueueStorePrefetch extends AbstractPendingMessageCursor implements Message
} }
public void start() throws Exception { public void start() throws Exception {
store.resetBatching();
} }
public void stop() throws Exception { public void stop() throws Exception {