User: slaboure Date: 02/01/12 08:52:09 Modified: src/main/org/jboss/ha/framework/server DistributedStateImpl.java DistributedStateImplMBean.java Log: Provide a listContent and listXmlContent for debugging purposes (useful with HTTP/JMX) Revision Changes Path 1.8 +72 -7 jbossmx/src/main/org/jboss/ha/framework/server/DistributedStateImpl.java Index: DistributedStateImpl.java =================================================================== RCS file: /cvsroot/jboss/jbossmx/src/main/org/jboss/ha/framework/server/DistributedStateImpl.java,v retrieving revision 1.7 retrieving revision 1.8 diff -u -r1.7 -r1.8 --- DistributedStateImpl.java 2002/01/03 04:00:52 1.7 +++ DistributedStateImpl.java 2002/01/12 16:52:08 1.8 @@ -29,7 +29,7 @@ * * @author <a href="mailto:[EMAIL PROTECTED]">Sacha Labourey</a>. * @author <a href="mailto:[EMAIL PROTECTED]">Bill Burke</a>. - * @version $Revision: 1.7 $ + * @version $Revision: 1.8 $ * * <p><b>Revisions:</b><br> * <p><b>2001/11/26: Sacha Labourey</b> @@ -54,6 +54,7 @@ protected org.jboss.logging.Logger log = null; protected MBeanServer mbeanServer = null; + protected String name = null; // Static --------------------------------------------------------c @@ -83,11 +84,11 @@ // we will need to redesign the way HAPartitions and its sub-protocols are // registered with JMX. They will most probably be independant JMX services. // - String name = "jboss:service=" + SERVICE_NAME + + this.name = "jboss:service=" + SERVICE_NAME + ",partitionName=" + this.partition.getPartitionName(); - ObjectName jmxName = new ObjectName(name); + ObjectName jmxName = new ObjectName(this.name); mbeanServer.registerMBean(this, jmxName); - org.jboss.system.Registry.bind (name, this); + org.jboss.system.Registry.bind (this.name, this); } public void start () throws Exception @@ -96,9 +97,73 @@ public void stop () throws Exception { - String name = "jboss:service=" + SERVICE_NAME + - ",partitionName=" + this.partition.getPartitionName(); - org.jboss.system.Registry.unbind (name); + org.jboss.system.Registry.unbind (this.name); + ObjectName jmxName = new ObjectName(this.name); + mbeanServer.unregisterMBean (jmxName); + } + + public String listContent () throws Exception + { + StringBuffer result = new StringBuffer (); + Collection cats = this.getAllCategories (); + java.util.Iterator catsIter = cats.iterator (); + while (catsIter.hasNext ()) + { + String category = (String)catsIter.next (); + java.util.Iterator keysIter = this.getAllKeys(category).iterator (); + + result.append ("-----------------------------------------------\n"); + result.append ("Category : ").append (category).append ("\n\n"); + result.append ("KEY\t:\tVALUE\n"); + + while (keysIter.hasNext ()) + { + String key = (String)keysIter.next (); + String value = this.get (category, key).toString (); + result.append ("\"").append(key).append ("\"\t:\t\"").append (value).append("\"\n"); + } + + result.append ("\n"); + + } + + return result.toString (); + } + + public String listXmlContent () throws Exception + { + StringBuffer result = new StringBuffer (); + Collection cats = this.getAllCategories (); + java.util.Iterator catsIter = cats.iterator (); + + result.append ("<DistributedState>\n"); + + while (catsIter.hasNext ()) + { + String category = (String)catsIter.next (); + java.util.Iterator keysIter = this.getAllKeys(category).iterator (); + + result.append ("\t<Category>\n"); + result.append ("\t\t<CategoryName>").append (category).append ("</CategoryName>\n"); + + while (keysIter.hasNext ()) + { + String key = (String)keysIter.next (); + String value = this.get (category, key).toString (); + result.append ("\t\t<Entry>\n"); + result.append ("\t\t\t<Key>").append (key).append ("</Key>\n"); + result.append ("\t\t\t<Value>").append (value).append ("</Value>\n"); + result.append ("\t\t</Entry>\n"); + result.append ("\"").append(key).append ("\"\t:\t\"").append (value).append("\"\n"); + } + + result.append ("\t</Category>\n"); + + } + + result.append ("</DistributedState>\n"); + + return result.toString (); } // DistributedState implementation ---------------------------------------------- 1.2 +3 -1 jbossmx/src/main/org/jboss/ha/framework/server/DistributedStateImplMBean.java Index: DistributedStateImplMBean.java =================================================================== RCS file: /cvsroot/jboss/jbossmx/src/main/org/jboss/ha/framework/server/DistributedStateImplMBean.java,v retrieving revision 1.1 retrieving revision 1.2 diff -u -r1.1 -r1.2 --- DistributedStateImplMBean.java 2001/12/29 16:10:10 1.1 +++ DistributedStateImplMBean.java 2002/01/12 16:52:09 1.2 @@ -13,7 +13,7 @@ * @see <related> * * @author <a href="mailto:[EMAIL PROTECTED]">Sacha Labourey</a>. - * @version $Revision: 1.1 $ + * @version $Revision: 1.2 $ * * <p><b>Revisions:</b> * @@ -25,5 +25,7 @@ public interface DistributedStateImplMBean extends org.jboss.ha.framework.interfaces.DistributedState { + public String listContent () throws Exception; + public String listXmlContent () throws Exception; }
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development