User: dbudworth
Date: 01/11/27 16:55:29
Modified: src/main/org/jboss/mq/server QueueManager.java
TopicManager.java
Log:
Added support for deep topic and queue names
Passes run-basic-testsuite, so if something is broken the test needs updating.
TopicManager/QueueManager, uses org.jboss.naming.Util to auto-create subcontexts
PersistenceManager/MessageLog updated to support deep subdirectories in
db/jbossmq/file
Revision Changes Path
1.6 +4 -2 jbossmq/src/main/org/jboss/mq/server/QueueManager.java
Index: QueueManager.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/QueueManager.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- QueueManager.java 2001/11/10 21:38:05 1.5
+++ QueueManager.java 2001/11/28 00:55:29 1.6
@@ -21,13 +21,15 @@
import org.jboss.mq.*;
import org.jboss.system.ServiceMBeanSupport;
+import org.jboss.naming.Util;
+
/**
* This class is a message queue which is stored (hashed by Destination) on the
* JMS provider
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a>
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class QueueManager extends ServiceMBeanSupport implements QueueManagerMBean
{
@@ -120,7 +122,7 @@
{
subctx = ctx.createSubcontext("queue");
}
- subctx.rebind(queueName, queue);
+ Util.rebind(subctx,queueName,queue);
}
1.6 +3 -3 jbossmq/src/main/org/jboss/mq/server/TopicManager.java
Index: TopicManager.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/TopicManager.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- TopicManager.java 2001/11/10 21:38:05 1.5
+++ TopicManager.java 2001/11/28 00:55:29 1.6
@@ -22,6 +22,7 @@
import org.jboss.mq.*;
import org.jboss.system.ServiceMBeanSupport;
import org.jboss.mq.DurableSubcriptionID;//Typo!!!
+import org.jboss.naming.Util;
/**
* This class is a message queue which is stored (hashed by Destination) on the
@@ -29,7 +30,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a>
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class TopicManager
extends ServiceMBeanSupport
@@ -124,8 +125,7 @@
{
subctx = ctx.createSubcontext("topic");
}
- subctx.rebind(topicName, topic);
-
+ Util.rebind(subctx,topicName,topic);
}
protected void stopService()
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
