QPID-3604 Added sync() after sending message stop for each subscriber.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1235553 13f79535-47bb-0310-9956-ffa450edef68
ralphbean · Jan 24, 2012 · f857cea · f857cea
1 parent 90a3233
commit f857cea
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -800,6 +800,7 @@ public void sendSuspendChannel(boolean suspend) throws AMQException, FailoverExc
                 getQpidSession().messageStop(String.valueOf(consumer.getConsumerTag()),
                                              Option.UNRELIABLE);
             }
+            sync();
         }
         else
         {