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();