HORNETQ-477 - Queues bound to wildcard addresses canoot be deleted

hornetq · Aug 16, 2010 · 5b9fc0a · 5b9fc0a
1 parent cbf622e
commit 5b9fc0a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/main/org/hornetq/core/postoffice/impl/AddressImpl.java b/src/main/org/hornetq/core/postoffice/impl/AddressImpl.java
@@ -62,7 +62,10 @@ public List<Address> getLinkedAddresses()
 
    public void addLinkedAddress(final Address address)
    {
-      linkedAddresses.add(address);
+      if(!linkedAddresses.contains(address))
+      {
+         linkedAddresses.add(address);
+      }
    }
 
    public void removeLinkedAddress(final Address actualAddress)

diff --git a/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java b/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java
@@ -181,7 +181,7 @@ public void connectionClosed()
    }
 
 
-   public void _testQueueWithWildcard() throws Exception
+   public void testQueueWithWildcard() throws Exception
    {
       session.createQueue("a.b", "queue1");
       session.createTemporaryQueue("a.#", "queue2");
@@ -221,7 +221,7 @@ public void _testQueueWithWildcard() throws Exception
    }
 
 
-   public void _testQueueWithWildcard2() throws Exception
+   public void testQueueWithWildcard2() throws Exception
    {
       session.createQueue("a.b", "queue1");
       session.createTemporaryQueue("a.#", "queue2");