[jboss-cvs] JBoss Messaging SVN: r1374 - in trunk/src/main/org/jboss/messaging/core: . plugin
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Sep 28 08:19:00 EDT 2006
Author: timfox
Date: 2006-09-28 08:18:58 -0400 (Thu, 28 Sep 2006)
New Revision: 1374
Modified:
trunk/src/main/org/jboss/messaging/core/ChannelSupport.java
trunk/src/main/org/jboss/messaging/core/plugin/JDBCPersistenceManager.java
Log:
Small ref counting fix
Modified: trunk/src/main/org/jboss/messaging/core/ChannelSupport.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/ChannelSupport.java 2006-09-28 11:55:53 UTC (rev 1373)
+++ trunk/src/main/org/jboss/messaging/core/ChannelSupport.java 2006-09-28 12:18:58 UTC (rev 1374)
@@ -449,7 +449,6 @@
{
synchronized (deliveryLock)
{
- //return messageRefs.size() + refsInStorage + deliveries.size();
return messageRefs.size() + deliveries.size();
}
}
Modified: trunk/src/main/org/jboss/messaging/core/plugin/JDBCPersistenceManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/JDBCPersistenceManager.java 2006-09-28 11:55:53 UTC (rev 1373)
+++ trunk/src/main/org/jboss/messaging/core/plugin/JDBCPersistenceManager.java 2006-09-28 12:18:58 UTC (rev 1374)
@@ -2310,6 +2310,8 @@
//First time so persist the message
storeMessage(m, psInsertMessage);
+ m.setPersisted(true);
+
added = true;
}
else
More information about the jboss-cvs-commits
mailing list