User: pkendall
Date: 01/08/16 18:21:38
Modified: src/main/org/jboss/mq SpyMessageConsumer.java
Log:
Fix message listener acknowledgements
Revision Changes Path
1.3 +6 -3 jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java
Index: SpyMessageConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyMessageConsumer.java 2001/08/16 04:04:40 1.2
+++ SpyMessageConsumer.java 2001/08/17 01:21:38 1.3
@@ -29,7 +29,7 @@
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyMessageConsumer implements MessageConsumer, SpyConsumer, Runnable {
@@ -351,11 +351,14 @@
if( mes instanceof SpyEncapsulatedMessage ) {
message = ((SpyEncapsulatedMessage)mes).getMessage();
}
- thisListener.onMessage(message);
- if (session.transacted) {
+ if(session.transacted){
session.connection.spyXAResourceManager.ackMessage(session.currentTransactionId, mes);
- } else if (session.acknowledgeMode == session.AUTO_ACKNOWLEDGE ||
session.acknowledgeMode == session.DUPS_OK_ACKNOWLEDGE) {
+ }
+
+ thisListener.onMessage(message);
+
+ if (!session.transacted && session.acknowledgeMode ==
session.AUTO_ACKNOWLEDGE || session.acknowledgeMode == session.DUPS_OK_ACKNOWLEDGE) {
mes.doAcknowledge();
}
mes = null;
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
