Author: chirino
Date: Sun Dec 31 09:32:40 2006
New Revision: 491452

URL: http://svn.apache.org/viewvc?view=rev&rev=491452
Log:
Fix RecoveryBrokerTest that I messed up :)

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java?view=diff&rev=491452&r1=491451&r2=491452
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java Sun Dec 31 09:32:40 2006
@@ -48,7 +48,7 @@
     private String subscriberName;
     private Destination regionDestination;
 
-    boolean empty=true;
+    boolean empty;
 	private MessageId firstMessageId;
 	private MessageId lastMessageId;
 
@@ -65,7 +65,16 @@
         this.subscriberName=subscriberName;
     }
 
-    public void start() throws Exception{
+    public void start() throws Exception {
+        if(batchList.isEmpty()){
+            try{
+                fillBatch();
+            }catch(Exception e){
+                log.error("Failed to fill batch",e);
+                throw new RuntimeException(e);
+            }
+            empty = batchList.isEmpty();
+        }    	
     }
 
     public void stop() throws Exception{