User: dmaplesden
Date: 01/09/03 19:22:42
Modified: src/main/org/jboss/mq/pm/file PersistenceManager.java
MessageLog.java
Log:
Changed initialisation to use "jboss.system.home" as file anchor.
Revision Changes Path
1.6 +6 -9 jbossmq/src/main/org/jboss/mq/pm/file/PersistenceManager.java
Index: PersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/file/PersistenceManager.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- PersistenceManager.java 2001/09/02 21:33:21 1.5
+++ PersistenceManager.java 2001/09/04 02:22:42 1.6
@@ -35,7 +35,7 @@
* persistence.
*
* @author Paul Kendall ([EMAIL PROTECTED])
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class PersistenceManager extends ServiceMBeanSupport implements
PersistenceManagerMBean, org.jboss.mq.pm.PersistenceManager
{
@@ -47,7 +47,6 @@
// The directory where persistence data should be stored
String dataDirectory;
- URL dataDirURL;
File dataDirFile;
//tx manager
org.jboss.mq.pm.TxManager txManager;
@@ -114,9 +113,8 @@
*/
public void initService() throws Exception
{
- URL configFile = getClass().getClassLoader().getResource("jboss.jcml");
- dataDirURL = new URL(configFile, dataDirectory);
- dataDirFile = new File(dataDirURL.getFile());
+ File jbossHome = new File(System.getProperty("jboss.system.home"));
+ dataDirFile = new File(jbossHome, dataDirectory);
JMSServer server = (JMSServer)getServer().invoke(new
ObjectName(org.jboss.mq.server.JBossMQServiceMBean.OBJECT_NAME), "getJMSServer", new
Object[]{}, new String[]{});
server.setPersistenceManager(this);
}
@@ -223,8 +221,8 @@
{
try
{
- URL logDir = new URL(dataDirURL, dest.toString());
- MessageLog log = new MessageLog(logDir.getFile());
+ File logDir = new File(dataDirFile, dest.toString());
+ MessageLog log = new MessageLog(logDir);
LogInfo info = new LogInfo(log, dest);
synchronized (messageLogs)
{
@@ -253,8 +251,7 @@
{
try
{
- URL logDir = new URL(dataDirURL, dest.toString());
- java.io.File file = new java.io.File(logDir.getFile());
+ File file = new File(dataDirFile, dest.toString());
LogInfo logInfo;
synchronized (messageLogs)
{
1.3 +4 -4 jbossmq/src/main/org/jboss/mq/pm/file/MessageLog.java
Index: MessageLog.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/file/MessageLog.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- MessageLog.java 2001/08/17 03:04:05 1.2
+++ MessageLog.java 2001/09/04 02:22:42 1.3
@@ -24,7 +24,7 @@
*
* @created August 16, 2001
* @author: Paul Kendall ([EMAIL PROTECTED])
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class MessageLog {
@@ -47,10 +47,10 @@
/////////////////////////////////////////////////////////////////////
// Constructor
/////////////////////////////////////////////////////////////////////
- public MessageLog( String fileName )
+ public MessageLog( File file )
throws JMSException {
- queueName = new File( fileName );
- queueName.mkdir();
+ queueName = file;
+ queueName.mkdirs();
}
/////////////////////////////////////////////////////////////////////
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
