[jboss-cvs] JBossAS SVN: r74988 - trunk/jbossmq/src/main/org/jboss/mq.

[jboss-cvs-commits at lists.jboss.org]

Author: adrian at jboss.org
Date: 2008-06-24 10:27:20 -0400 (Tue, 24 Jun 2008)
New Revision: 74988

Modified:
   trunk/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java
Log:
[JBAS-5670] - NACK messages that will never be delivered in MessageConsumer.close()

Modified: trunk/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java
===================================================================
--- trunk/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java	2008-06-24 14:26:45 UTC (rev 74987)
+++ trunk/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java	2008-06-24 14:27:20 UTC (rev 74988)
@@ -525,6 +525,21 @@
 
          if (trace)      
             log.trace("Message consumer closing. " + this);
+         
+         while (messages.isEmpty() == false)
+         {
+            SpyMessage mes = (SpyMessage) messages.removeFirst();
+            if (trace)
+               log.trace("close() nacking undelivered message mes=" + mes.getJMSMessageID() + " " + this);
+            try
+            {
+               session.connection.send(mes.getAcknowledgementRequest(false));
+            }
+            catch (Exception e)
+            {
+               log.debug("Error nacking message: " + mes.getJMSMessageID(), e);
+            }
+         }
          messages.notifyAll();
       }