[
https://issues.apache.org/jira/browse/ARTEMIS-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550849#comment-16550849
]
Miroslav Minárik commented on ARTEMIS-589:
------------------------------------------
Hi
By my opinium missing prefetch setting is not only for improvement, it is bug,
because server is distributing messages (without limit?) to first connected
consumer. Server sent to my test client a lot of messages (i not found rule for
this, sometimes 10, sometimes 20, etc.) without client acknowledments. Those
messages are unavailable for others (before client stop).
Simple testing script with demonstration of uncontrolled prefetch is in
attachment ( it requires bash and nc (netcat)). First parameter is servername,
second is optional for send message mode (filling of message queue). On server
must be prepared persistent queue "queue1" (with behaviours queue as in AMQ5) -
setting follows bellow.
Can you change type of this issue to Bug?
----
Definition of queue1 (insert in <address-setting> element of broker.xml )
{code}
<address-setting match="queue1">
<default-address-routing-type>ANYCAST</default-address-routing-type>
<dead-letter-address>DLQ</dead-letter-address>
<!-- R: 10 50 250 1250 s -->
<max-delivery-attempts>4</max-delivery-attempts>
<redelivery-delay-multiplier>5</redelivery-delay-multiplier>
<redelivery-delay>10000</redelivery-delay>
<expiry-address>ExpiryQueue</expiry-address>
<max-size-bytes>10000000</max-size-bytes>
<page-size-bytes>1000000</page-size-bytes>
<address-full-policy>PAGE</address-full-policy>
<auto-delete-queues>false</auto-delete-queues>
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
<redistribution-delay>0</redistribution-delay>
</address-setting>
{code}
> Add prefetch control support via STOMP
> --------------------------------------
>
> Key: ARTEMIS-589
> URL: https://issues.apache.org/jira/browse/ARTEMIS-589
> Project: ActiveMQ Artemis
> Issue Type: Improvement
> Reporter: Lionel Cons
> Priority: Major
> Attachments: stomp_test.sh
>
>
> ActiveMQ 5.x supports prefetch control over STOMP via the
> {{activemq.prefetchSize}} header on the {{SUBSCRIBE}} frame.
> Artemis does not seem to support it. Could it be added please?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
