You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/09/10 16:12:14 UTC

svn commit: r574255 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java

Author: arnaudsimon
Date: Mon Sep 10 07:12:14 2007
New Revision: 574255

URL: http://svn.apache.org/viewvc?rev=574255&view=rev
Log:
added message flow mode window 

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

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=574255&r1=574254&r2=574255&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java Mon Sep 10 07:12:14 2007
@@ -306,9 +306,10 @@
     {
         getQpidSession().messageSubscribe(queueName.toString(), tag.toString(), Session.TRANSFER_CONFIRM_MODE_REQUIRED,
                                           Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE,
-                                          new MessagePartListenerAdapter((BasicMessageConsumer_0_10) consumer),
-                                          null, consumer.isNoLocal() ? Option.NO_LOCAL : Option.NO_OPTION,
+                                          new MessagePartListenerAdapter((BasicMessageConsumer_0_10) consumer), null,
+                                          consumer.isNoLocal() ? Option.NO_LOCAL : Option.NO_OPTION,
                                           consumer.isExclusive() ? Option.EXCLUSIVE : Option.NO_OPTION);
+        getQpidSession().messageFlowMode(tag.toString(), Session.MESSAGE_FLOW_MODE_WINDOW);
         // We need to sync so that we get notify of an error.
         getQpidSession().sync();
         getCurrentException();