[hornetq-commits] JBoss hornetq SVN: r9513 - trunk/src/main/org/hornetq/core/postoffice/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-08-05 17:32:38 -0400 (Thu, 05 Aug 2010)
New Revision: 9513

Modified:
   trunk/src/main/org/hornetq/core/postoffice/impl/DuplicateIDCacheImpl.java
Log:
Delete duplicateID only if persist=true, or the users will get unnecessary Exceptions

Modified: trunk/src/main/org/hornetq/core/postoffice/impl/DuplicateIDCacheImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/postoffice/impl/DuplicateIDCacheImpl.java	2010-08-05 15:07:36 UTC (rev 9512)
+++ trunk/src/main/org/hornetq/core/postoffice/impl/DuplicateIDCacheImpl.java	2010-08-05 21:32:38 UTC (rev 9513)
@@ -172,16 +172,19 @@
          // reclaimed
          id.a = new ByteArrayHolder(duplID);
 
-         try
+         if (persist)
          {
-            storageManager.deleteDuplicateID(id.b);
+            try
+            {
+               storageManager.deleteDuplicateID(id.b);
+            }
+            catch (Exception e)
+            {
+               DuplicateIDCacheImpl.log.warn("Error on deleting duplicate cache", e);
+            }
+   
+            id.b = recordID;
          }
-         catch (Exception e)
-         {
-            DuplicateIDCacheImpl.log.warn("Error on deleting duplicate cache", e);
-         }
-
-         id.b = recordID;
       }
       else
       {