[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-commits
Subject:    svn commit: r639667 -
From:       chirino () apache ! org
Date:       2008-03-21 15:30:01
Message-ID: 20080321153003.D5B851A9832 () eris ! apache ! org
[Download RAW message or body]

Author: chirino
Date: Fri Mar 21 08:29:55 2008
New Revision: 639667

URL: http://svn.apache.org/viewvc?rev=639667&view=rev
Log:


Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java


Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
                
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apach \
e/activemq/network/NetworkConnector.java?rev=639667&r1=639666&r2=639667&view=diff \
                ==============================================================================
                
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java \
                (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java \
Fri Mar 21 08:29:55 2008 @@ -19,6 +19,7 @@
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -173,8 +174,16 @@
         dests = destsList.toArray(new ActiveMQDestination[destsList.size()]);
         result.setStaticallyIncludedDestinations(dests);
         if (durableDestinations != null) {
-            ActiveMQDestination[] dest = new \
                ActiveMQDestination[durableDestinations.size()];
-            dest = (ActiveMQDestination[])durableDestinations.toArray(dest);
+            
+            HashSet<ActiveMQDestination> topics = new \
HashSet<ActiveMQDestination>(); +            for (ActiveMQDestination d : \
durableDestinations) { +                if( d.isTopic() ) {
+                    topics.add(d);
+                }
+            }
+            
+            ActiveMQDestination[] dest = new ActiveMQDestination[topics.size()];
+            dest = (ActiveMQDestination[])topics.toArray(dest);
             result.setDurableDestinations(dest);
         }
         return result;


[prev in list] [next in list] [prev in thread] [next in thread]