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

[arnaudsimon]

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();