Loading...

XML

Word

Printable

Steps to Reproduce:
Hide

1. Add to activemq.xml:

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600&transport.prefetch=2"/>

2. start Fuse
3. using hawtio, for example, send 5 messages.
4. Consume 1 message, using consumer from https://issues.jboss.org/browse/ENTMQ-792. (Modify that consumer to consume 1 text message)

mvn -P consume10

5. Check the value of JMSRedelivered header of the second and third messages is now set to 'true'.
Show
1. Add to activemq.xml: <transportConnector name= "amqp" uri= "amqp: //0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600&transport.prefetch=2" /> 2. start Fuse 3. using hawtio, for example, send 5 messages. 4. Consume 1 message, using consumer from https://issues.jboss.org/browse/ENTMQ-792 . (Modify that consumer to consume 1 text message) mvn -P consume10 5. Check the value of JMSRedelivered header of the second and third messages is now set to 'true'.

Similar to https://issues.jboss.org/browse/ENTMQ-813?focusedCommentId=13017592&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13017592 , but for non-persistent messages.When setting transport.prefetch=2, and consuming 1 non persitent message from the queue, the next 2 messages will get JMSRedelivered=true.That's not a regression of the Rollup 2 patch, as the same behaiviour is in JBoss Fuse (6.1.1.redhat-412).

is related to

ENTMQ-792 When an AMQP client receives some messages from a queue, all JMSRedelivered headers of the remained messages are changed to true.

ENTMQ-813 In AMQP, prefetchSize is hard-coded to 100

relates to

ENTMQ-911 Prefetched messages are not deleted from the queue when calling purge()