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());
|