ft420 wrote:
hi
1.
we are testing the performance of fanout by increasing no of recv queues.
Current scenario is there are 4  queues in fanout exchange we were trying
out FlowControl::messageWindow option for optimization purpose.
fanoutsend application sends 100000 messages change made in fanoutrecv was FlowControl::messageWindow with 100, 5000, 10000 but the fanoutrecv exe hangs, please let me know where am i going wrong?

Can you attach the code (or diff to the example) that you are using?

2.
One more thing is, in fanout sample code session.sync() is not called after
sending messages which are put using async session.

However the sending of the last message uses a synchronous session so it will not complete until the message (and those sent earlier) have all completed.

but as per
Message_Tutorial pdf to optimize message transfer using async session
session.sync() should be called..
My query is does this concept apply to all exchange types?

Yes it does.

3.
what is default value of bounds in ConnectionSettings?

The default value is 2 (i.e. 2 * the max frame size, the default for which is 65535 bytes).

--Gordon.

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:[email protected]

Reply via email to