From 4d0e57261cf613fb62e6cf45f6e47452abf84230 Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Mon, 22 Sep 2008 19:17:24 +0000
Subject: [PATCH] Fix for https://issues.apache.org/activemq/browse/AMQ-1943

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@697953 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
index 8d2e044191..50a30fa92c 100755
--- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
@@ -714,6 +714,7 @@ public class DefaultJDBCAdapter implements JDBCAdapter {
                         count++;
                     } else {
                         LOG.debug("Stopped recover next messages");
+                        break;
                     }
                 }
             } else {
@@ -722,6 +723,7 @@ public class DefaultJDBCAdapter implements JDBCAdapter {
                         count++;
                     } else {
                         LOG.debug("Stopped recover next messages");
+                        break;
                     }
                 }
             }