which one?

On 12/31/06, chirino@apache.org <chirino@apache.org> wrote:
> 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{
>
>
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com