activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Patrick Vansevenant (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AMQ-6500) Consuming problem with topics in ActiveMQ 5.14.1 with AMQP Qpid client
Date Thu, 10 Nov 2016 10:34:58 GMT

    [ https://issues.apache.org/jira/browse/AMQ-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15653704#comment-15653704
] 

Patrick Vansevenant commented on AMQ-6500:
------------------------------------------

I have added a unit test that shows the issue : "JmsClientUnitTest.java".

The unit test sends 1000 topic messages and only 501 are received.

> Consuming problem with topics in ActiveMQ 5.14.1 with AMQP Qpid client
> ----------------------------------------------------------------------
>
>                 Key: AMQ-6500
>                 URL: https://issues.apache.org/jira/browse/AMQ-6500
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: AMQP
>    Affects Versions: 5.14.1
>            Reporter: Patrick Vansevenant
>         Attachments: JmsClientUnitTest.java, activemq.xml, status when subscriber connects.png
>
>
> There could only be 500 topic messages be consumed with the AMQP Qpid client with ActiveMQ
5.14.1.
> Specific settings :
> - No prefetch sizes are set in a policyEntry of the activemq.xml.
> - No prefetch sizes are set in the brokerURL in the client code.
> We get the following situation (subscriber info) at the moment a subscriber
> connects with the Qpid client.
> The Inflight value becomes -1000 what is very strange.
> Pending Queue Size  | Inflight | Enqueued | Dequeued | Prefetch
> 0                                | -1000  | 0               | 0                | 0
> We get the following situation when one topic message is published.
> The Inflight value increased with 2.
> Pending Queue Size  | Inflight | Enqueued | Dequeued | Prefetch
> 0                                | -998    | 1                | 1               | 0
> We get the following situation when 500 topic messages are published.
> The Inflight value is now 0 and the 500 messages are consumed.
> Pending Queue Size  | Inflight | Enqueued | Dequeued | Prefetch
> 0                                | 0         | 500            | 500           | 0
> At the moment message 501 is published increases the "Pending Queue Size" and the messages
"Enqueued" as well. The "Dequeued" messages remains 500 and message 501 can't be consumed
by the subscriber !
> Pending Queue Size  | Inflight | Enqueued | Dequeued | Prefetch
> 1                                | 0          | 501          | 500            | 0
> Do somebody know what happens ?  Do I something wrong or is it a real bug ?
> Patrick



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message