qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r574255 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Date Mon, 10 Sep 2007 14:12:14 GMT
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();



Mime
View raw message