Author: clebert.suconic(a)jboss.com Date: 2010-08-04 01:26:04 -0400 (Wed, 04 Aug 2010) New Revision: 9502 Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java Log: tweaks on delete messages after restart Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java =================================================================== --- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2010-08-03 19:21:41 UTC (rev 9501) +++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java 2010-08-04 05:26:04 UTC (rev 9502) @@ -1016,7 +1016,16 @@ if (!referencedMessages.contains(msg.getMessageID())) { log.info("Deleting unreferenced message id=" + msg.getMessageID() + " from the journal"); - deleteMessage(msg.getMessageID()); + // Something after routing could delete messages + // So we ignore eventual ignores + try + { + deleteMessage(msg.getMessageID()); + } + catch (Exception ignored) + { + log.warn("It wasn't possible to delete message " + msg.getMessageID()); + } } }