User: dmaplesden
Date: 01/08/26 14:27:59
Modified: src/main/org/jboss/mq/server BasicQueue.java
Log:
Set message redelivered flag after message delivery was negatively acknowledged,
usually after a transaction rollback.
Revision Changes Path
1.5 +3 -1 jbossmq/src/main/org/jboss/mq/server/BasicQueue.java
Index: BasicQueue.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/BasicQueue.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- BasicQueue.java 2001/08/17 03:04:06 1.4
+++ BasicQueue.java 2001/08/26 21:27:59 1.5
@@ -30,7 +30,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
//abstract public class BasicQueue implements Runnable {
public class BasicQueue {
@@ -224,6 +224,8 @@
// Was it a negative acknowledge??
if ( !item.isAck ) {
+ //set redelivered flag
+ m.setJMSRedelivered(true);
Runnable task = new RestoreMessageTask( m, item.subscriberId );
server.getPersistenceManager().getTxManager().addPostCommitTask( txId,
task );
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
