[openamq-dev] amq_server message limit

[Pieter Hintjens]

On Thu, May 15, 2008 at 8:31 PM, Pieter Hintjens <ph at imatix.com> wrote:

>>  It looks like the code that publishes messages to the queue is synchronized
>> with the code that sends messages out to the network, and messages are
>> accumulated before they are published. That's why queue message limit does
>> not work in this case. But this is just a theory at this point...

Hi Dmitri,

Attached are a couple of patches, one for base2/asl and one for
openamq/server.  What these do is implement a simple credit based flow
control inside the server between the queue and the protocol agent,
which should (if my calculations are correct, as the phrase goes),
cause messages to remain in the queue rather than being offloaded for
transmission when the network is very slow and/or the client is very
slow.

Disclaimer: I've not got the test scenario set-up here so I can only
test that these changes do not break anything.  However if you are
able to test these patches against your slow network scenario it
should be fairly clear whether this internal synchronization (or lack
thereof) is in fact the issue.

Best regards,
Pieter
-------------- next part --------------
A non-text attachment was scrubbed...
Name: base2_asl.patch
Type: application/octet-stream
Size: 1847 bytes
Desc: not available
Url : http://lists.openamq.org/pipermail/openamq-dev/attachments/20080519/70fdc634/attachment.obj 
-------------- next part --------------
A non-text attachment was scrubbed...
Name: openamq_server.patch
Type: application/octet-stream
Size: 5357 bytes
Desc: not available
Url : http://lists.openamq.org/pipermail/openamq-dev/attachments/20080519/70fdc634/attachment-0001.obj