diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java index 68b8aa9de5..618dc846cb 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java @@ -111,7 +111,7 @@ public class DefaultStatementProvider implements StatementProvider { public String getFindAllDurableSubsStatment() { return "SELECT SELECTOR, SUB_NAME, CLIENT_ID" + - "FROM "+getTablePrefix()+durableSubAcksTableName+ + " FROM "+getTablePrefix()+durableSubAcksTableName+ " WHERE CONTAINER=?"; }