activemq-commits mailing list archives

Author: chirino
Date: Fri Oct 26 13:20:25 2007
New Revision: 588767

URL: http://svn.apache.org/viewvc?rev=588767&view=rev
Log:
The caching of the prepared statement for updating the last ack was wrong.
Reported at http://www.nabble.com/Is-this-a-bug-in-DefaultJDBCAdapter.java--tf1890445s2354.html#a5170127

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java?rev=588767&r1=588766&r2=588767&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
Fri Oct 26 13:20:25 2007
@@ -325,7 +325,7 @@
 
     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());