[hornetq-commits] JBoss hornetq SVN: r12105 - branches/Branch_2_2_AS7/src/main/org/hornetq/core/postoffice/impl.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Feb 9 17:18:44 EST 2012


Author: jbertram
Date: 2012-02-09 17:18:43 -0500 (Thu, 09 Feb 2012)
New Revision: 12105

Modified:
   branches/Branch_2_2_AS7/src/main/org/hornetq/core/postoffice/impl/SimpleAddressManager.java
Log:
[HORNETQ-847] createQueue not idempotent

Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/postoffice/impl/SimpleAddressManager.java
===================================================================
--- branches/Branch_2_2_AS7/src/main/org/hornetq/core/postoffice/impl/SimpleAddressManager.java	2012-02-09 22:17:52 UTC (rev 12104)
+++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/postoffice/impl/SimpleAddressManager.java	2012-02-09 22:18:43 UTC (rev 12105)
@@ -16,6 +16,7 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
+import org.hornetq.api.core.HornetQException;
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.core.logging.Logger;
 import org.hornetq.core.postoffice.Address;
@@ -56,7 +57,7 @@
    {
       if (nameMap.putIfAbsent(binding.getUniqueName(), binding) != null)
       {
-         throw new IllegalStateException("Binding already exists " + binding);
+         throw new HornetQException(HornetQException.QUEUE_EXISTS, "Binding already exists " + binding);
       }
       
       if (log.isDebugEnabled())



More information about the hornetq-commits mailing list