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;
                     }
                 }
             }