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"); + } } }