User: chirino
Date: 01/07/10 20:23:31
Modified: src/main/org/jbossmq/server StateManagerMBean.java
StateManager.java
Log:
Change so that the state file used is configurable via JMX
Revision Changes Path
1.2 +5 -1 jbossmq/src/main/org/jbossmq/server/StateManagerMBean.java
Index: StateManagerMBean.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/StateManagerMBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- StateManagerMBean.java 2001/07/11 02:59:30 1.1
+++ StateManagerMBean.java 2001/07/11 03:23:31 1.2
@@ -48,12 +48,12 @@
*
* @see <related>
* @author Vincent Sheffer ([EMAIL PROTECTED])
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public interface StateManagerMBean
extends org.jboss.util.ServiceMBean
{
-}
+
// Public --------------------------------------------------------
@@ -65,3 +65,7 @@
// Public --------------------------------------------------------
+public java.lang.String getStateFile();
+
+public void setStateFile(java.lang.String newStateFile);
+}
\ No newline at end of file
1.2 +28 -8 jbossmq/src/main/org/jbossmq/server/StateManager.java
Index: StateManager.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/StateManager.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- StateManager.java 2001/07/11 02:59:30 1.1
+++ StateManager.java 2001/07/11 03:23:31 1.2
@@ -26,18 +26,19 @@
import javax.management.*;
import java.io.File;
+import java.net.URL;
+
/**
* This class is a simple User Manager. It handles credential issues.
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
-public class StateManager extends ServiceMBeanSupport implements StateManagerMBean,
MBeanRegistration, java.io.Serializable {
+public class StateManager extends ServiceMBeanSupport implements StateManagerMBean,
MBeanRegistration {
- //registered loggedOnClientIds
- transient private HashSet loggedOnClientIds;
+ private HashSet loggedOnClientIds;
@@ -147,10 +148,10 @@
loggedOnClientIds.remove(ID);
}
}
-
- transient org.apache.log4j.Category cat=
org.apache.log4j.Category.getInstance(StateManager.class);
- transient org.jbossmq.xml.XElement stateConfig;
+ org.apache.log4j.Category cat=
org.apache.log4j.Category.getInstance(StateManager.class);
+ org.jbossmq.xml.XElement stateConfig;
+ private String stateFile = "jbossmq-state.xml";
public StateManager() throws org.jbossmq.xml.XElementException
{
@@ -173,6 +174,15 @@
+/**
+ * Insert the method's description here.
+ * Creation date: (7/10/2001 11:17:33 PM)
+ * @return java.lang.String
+ */
+public java.lang.String getStateFile() {
+ return stateFile;
+}
+
public void initDurableSubscriptions(JMSServer server) throws
org.jbossmq.xml.XElementException {
//Set the known Ids
@@ -199,8 +209,9 @@
}
- public void loadConfig() throws java.io.IOException,
org.jbossmq.xml.XElementException {
- java.io.InputStream in =
getClass().getClassLoader().getResource("jbossmq.xml").openStream();
+ public void loadConfig() throws java.io.IOException,
org.jbossmq.xml.XElementException {
+ URL u = new URL(
getClass().getClassLoader().getResource("jboss.jcml"), stateFile);
+ java.io.InputStream in = u.openStream();
stateConfig = XElement.createFrom(in);
in.close();
}
@@ -289,4 +300,13 @@
}
}
+
+/**
+ * Insert the method's description here.
+ * Creation date: (7/10/2001 11:17:33 PM)
+ * @param newStateFile java.lang.String
+ */
+public void setStateFile(java.lang.String newStateFile) {
+ stateFile = newStateFile;
+}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
