[hornetq-commits] JBoss hornetq SVN: r8215 - trunk/src/main/org/hornetq/core/server/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Nov 4 18:34:51 EST 2009
Author: ataylor
Date: 2009-11-04 18:34:51 -0500 (Wed, 04 Nov 2009)
New Revision: 8215
Modified:
trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-188 - a few tweaks
Modified: trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java 2009-11-04 23:29:37 UTC (rev 8214)
+++ trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java 2009-11-04 23:34:51 UTC (rev 8215)
@@ -1401,7 +1401,16 @@
// One decrements the ref count, then the other stores a delete, the delete gets committed, but the first
// ack isn't committed, then the server crashes and on
// recovery the message is deleted even though the other ack never committed
- storageManager.deleteMessage(message.getMessageID());
+
+ //also note then when this happens as part of a trasaction its the tx commt of the ack that is important not this
+ try
+ {
+ storageManager.deleteMessage(message.getMessageID());
+ }
+ catch (Exception e)
+ {
+ log.warn("Unable to remove message id = " + message.getMessageID() + " please remove manually");
+ }
}
}
More information about the hornetq-commits
mailing list