qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raj...@apache.org
Subject svn commit: r583191 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Date Tue, 09 Oct 2007 15:21:30 GMT
Author: rajith
Date: Tue Oct  9 08:21:29 2007
New Revision: 583191

URL: http://svn.apache.org/viewvc?rev=583191&view=rev
Log:
Added window mode as the flow mode when we unsuspend a channel provided a listener is set

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=583191&r1=583190&r2=583191&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
Tue Oct  9 08:21:29 2007
@@ -450,6 +450,7 @@
                 {
                     if (consumer.getMessageListener() != null)
                     {
+                        getQpidSession().messageFlowMode(consumer.getConsumerTag().toString(),
Session.MESSAGE_FLOW_MODE_WINDOW);
                         getQpidSession().messageFlow(consumer.getConsumerTag().toString(),
Session.MESSAGE_FLOW_UNIT_MESSAGE,
                                                      MAX_PREFETCH);
                         // todo this



Mime
View raw message