[jboss-cvs] JBoss Messaging SVN: r3027 - trunk/src/main/org/jboss/messaging/core/impl.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Aug 22 09:24:36 EDT 2007
Author: timfox
Date: 2007-08-22 09:24:36 -0400 (Wed, 22 Aug 2007)
New Revision: 3027
Modified:
trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
Log:
PM interim commit 6
Modified: trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java 2007-08-22 13:18:52 UTC (rev 3026)
+++ trunk/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java 2007-08-22 13:24:36 UTC (rev 3027)
@@ -1058,10 +1058,8 @@
ps.close();
- conn.close();
+ ps = null;
- conn = ds.getConnection();
-
ps = conn.prepareStatement(getSQLStatement("LOAD_UNPAGED_REFS"));
ps.setLong(1, channelID);
@@ -1489,9 +1487,7 @@
List<Message> messagesStored = new ArrayList<Message>();
try
- {
- conn = ds.getConnection();
-
+ {
//Insert the tx record
if (!refsToAdd.isEmpty() || !refsToRemove.isEmpty())
{
More information about the jboss-cvs-commits
mailing list