summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
Diffstat (limited to 'java')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index a2b233b063..8b17dcf91f 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -386,14 +386,14 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM
if (o == null && _0_10session.isStarted())
{
_0_10session.getQpidSession().messageFlush
- (getConsumerTagString(), Option.UNRELIABLE);
+ (getConsumerTagString(), Option.UNRELIABLE, Option.SYNC);
_0_10session.getQpidSession().sync();
+ _0_10session.getQpidSession().messageFlow
+ (getConsumerTagString(), MessageCreditUnit.BYTE,
+ 0xFFFFFFFF, Option.UNRELIABLE);
if (getSession().prefetch())
{
_0_10session.getQpidSession().messageFlow
- (getConsumerTagString(), MessageCreditUnit.BYTE,
- 0xFFFFFFFF, Option.UNRELIABLE);
- _0_10session.getQpidSession().messageFlow
(getConsumerTagString(), MessageCreditUnit.MESSAGE,
_0_10session.getAMQConnection().getMaxPrefetch(),
Option.UNRELIABLE);