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 69f89ea9f4..56c9779bb1 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
@@ -325,7 +325,7 @@ public class DefaultJDBCAdapter implements JDBCAdapter {
 
     public void doSetLastAck(TransactionContext c, ActiveMQDestination destination, String clientId,
                              String subscriptionName, long seq) throws SQLException, IOException {
-        PreparedStatement s = c.getAddMessageStatement();
+        PreparedStatement s = c.getUpdateLastAckStatement();
         try {
             if (s == null) {
                 s = c.getConnection().prepareStatement(statements.getUpdateLastAckOfDurableSubStatement());