User: chirino
Date: 02/03/09 07:32:34
Modified: src/main/org/jboss/mq/pm/file PersistenceManager.java
Log:
Added some more logic so that you can undeploy a queue or topic. Still needs work
on the recovery side. Queue recovery will only happen the first time the queue is
deployed.
Revision Changes Path
1.21 +16 -1 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.20
retrieving revision 1.21
diff -u -r1.20 -r1.21
--- PersistenceManager.java 27 Feb 2002 09:24:25 -0000 1.20
+++ PersistenceManager.java 9 Mar 2002 15:32:34 -0000 1.21
@@ -41,7 +41,7 @@
* persistence.
*
* @author Paul Kendall ([EMAIL PROTECTED])
- * @version $Revision: 1.20 $
+ * @version $Revision: 1.21 $
*/
public class PersistenceManager
extends ServiceMBeanSupport
@@ -838,4 +838,19 @@
}
}
}
+ /*
+ * @see PersistenceManager#closeQueue(JMSDestination, SpyDestination)
+ */
+ public void closeQueue(JMSDestination jmsDest, SpyDestination dest) throws
JMSException
+ {
+ boolean debug = log.isDebugEnabled();
+ if (debug)
+ log.debug("closing destination: "+dest);
+
+ // Cleanup all stuff we loaded/opened
+ String queueName = dest.toString();
+ LogInfo info = (LogInfo)messageLogs.remove(queueName);
+ unrestoredMessages.remove(queueName);
+ }
+
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
