[hornetq-commits] JBoss hornetq SVN: r11809 - in branches/Branch_2_2_EAP/src/main/org/hornetq: core/management/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2011-12-02 05:13:07 -0500 (Fri, 02 Dec 2011)
New Revision: 11809

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/api/core/management/ClusterConnectionControl.java
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/management/impl/ClusterConnectionControlImpl.java
Log:
added management method on cluster connection to allow users to see what topology is known

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/api/core/management/ClusterConnectionControl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/api/core/management/ClusterConnectionControl.java	2011-12-02 05:50:23 UTC (rev 11808)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/api/core/management/ClusterConnectionControl.java	2011-12-02 10:13:07 UTC (rev 11809)
@@ -49,6 +49,10 @@
    boolean isForwardWhenNoConsumers();
 
    /**
+    * Return the Topology that this Cluster Connection knows about
+    */
+   String getTopology();
+   /**
     * Returns the maximum number of hops used by this cluster connection.
     */
    int getMaxHops();

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/management/impl/ClusterConnectionControlImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/management/impl/ClusterConnectionControlImpl.java	2011-12-02 05:50:23 UTC (rev 11808)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/management/impl/ClusterConnectionControlImpl.java	2011-12-02 10:13:07 UTC (rev 11809)
@@ -210,6 +210,18 @@
       }
    }
 
+   public String getTopology()
+   {
+      clearIO();
+      try
+      {
+         return clusterConnection.getTopology().describe();
+      }
+      finally
+      {
+         blockOnIO();
+      }
+   }
    public Map<String, String> getNodes() throws Exception
    {
       clearIO();