User: dmaplesden
Date: 01/09/09 20:26:44
Modified: src/main/org/jboss/mq/pm/rollinglogged
PersistenceManager.java
Log:
fix (lack of) persistence bug for durable subscribers to topics
Revision Changes Path
1.7 +5 -1
jbossmq/src/main/org/jboss/mq/pm/rollinglogged/PersistenceManager.java
Index: PersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/rollinglogged/PersistenceManager.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- PersistenceManager.java 2001/09/04 02:22:29 1.6
+++ PersistenceManager.java 2001/09/10 03:26:44 1.7
@@ -32,7 +32,7 @@
* This class manages all persistence related services.
*
* @author David Maplesden ([EMAIL PROTECTED])
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class PersistenceManager extends ServiceMBeanSupport implements
org.jboss.mq.pm.PersistenceManager, PersistenceManagerMBean
{
@@ -490,6 +490,10 @@
for (int j = 0; j < messages.length; j++)
{
messages[j].persistData = info;
+ if (dest instanceof org.jboss.mq.SpyTopic)
+ {
+ messages[j].durableSubscriberID =
((org.jboss.mq.SpyTopic)dest).getDurableSubscriptionID();
+ }
q.restoreMessage(messages[j]);
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
