You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/12/16 17:56:59 UTC
svn commit: r1646009 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
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