qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rgodf...@apache.org
Subject svn commit: r1646009 - /qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
Date Tue, 16 Dec 2014 16:56:59 GMT
Author: rgodfrey
Date: Tue Dec 16 16:56:59 2014
New Revision: 1646009

URL: http://svn.apache.org/r1646009
Log:
QPID-5099 : [Java Client] release pre-acquired messages after explicit consumer close

Modified:
    qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java

Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java?rev=1646009&r1=1646008&r2=1646009&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
(original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
Tue Dec 16 16:56:59 2014
@@ -645,6 +645,12 @@ public abstract class BasicMessageConsum
 
                 _receivingThread.interrupt();
             }
+
+
+            if(!(isBrowseOnly() || getSession().isClosing()))
+            {
+                rollback();
+            }
         }
     }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message