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