You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Matt Pavlovich (Jira)" <ji...@apache.org> on 2021/01/18 20:09:00 UTC
[jira] [Updated] (AMQ-4846) Using a selector on a virtual topic's
consumer queue makes dispatching very slow
[ https://issues.apache.org/jira/browse/AMQ-4846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matt Pavlovich updated AMQ-4846:
--------------------------------
Labels: close-pending (was: )
> Using a selector on a virtual topic's consumer queue makes dispatching very slow
> --------------------------------------------------------------------------------
>
> Key: AMQ-4846
> URL: https://issues.apache.org/jira/browse/AMQ-4846
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.9.0
> Environment: FreeBSD 9/amd64
> openjdk version "1.7.0_25"
> OpenJDK Runtime Environment (build 1.7.0_25-b15)
> OpenJDK 64-Bit Server VM (build 23.21-b01, mixed mode)
> AMQ 5.9.0
> Reporter: Attila Nagy
> Priority: Major
> Labels: close-pending
>
> I would like to use selectors on a virtual topic's consumer queue using STOMP. It works, but delivers messages in batches, like (columns in order: time elapsed since startup (1 sec resolution), messages received in that second, messages received so far):
> # python recv.py
> 0.986346960068 400 400
> 1.98636507988 0 400
> 2.98635101318 0 400
> 3.98635292053 0 400
> 4.98634409904 133 533
> 5.98635101318 0 533
> 6.98637294769 0 533
> 7.9863820076 0 533
> 8.98635411263 0 533
> 9.98635792732 0 533
> 10.9863569736 0 533
> 11.9863500595 0 533
> 12.986344099 0 533
> 13.9863789082 0 533
> 14.9863870144 0 533
> 15.9863469601 0 533
> 16.9863901138 0 533
> 17.9863479137 0 533
> 18.9863550663 0 533
> 19.9863619804 0 533
> 20.9863951206 0 533
> 21.9863500595 0 533
> 22.9863810539 0 533
> 23.9863579273 0 533
> 24.9864621162 0 533
> 25.986399889 0 533
> 26.9863541126 0 533
> 27.9863469601 0 533
> 28.9863550663 0 533
> 29.9863519669 0 533
> 30.9863519669 0 533
> 31.9863500595 0 533
> 32.9863729477 0 533
> 33.9864048958 0 533
> 34.98635602 133 666
> 35.9863491058 0 666
> 36.9863638878 0 666
> 37.9863810539 0 666
> 38.9863660336 0 666
> 39.9863491058 0 666
> 40.9863479137 0 666
> 41.9863479137 0 666
> 42.9863750935 0 666
> 43.9863889217 0 666
> 44.9863569736 0 666
> 45.9863500595 0 666
> 46.9863829613 0 666
> 47.9863619804 0 666
> 48.9863989353 0 666
> 49.9863688946 0 666
> 50.9863500595 0 666
> 51.9863629341 0 666
> 52.9863550663 0 666
> 53.9864459038 0 666
> 54.98635602 0 666
> 55.9863450527 0 666
> 56.9863591194 0 666
> 57.9863500595 0 666
> 58.9863801003 0 666
> 59.9863529205 0 666
> 60.9863679409 0 666
> 61.9863760471 0 666
> 62.9863500595 0 666
> 63.9863519669 0 666
> 64.986385107 134 800
> 65.9863569736 0 800
> 66.9863491058 0 800
> 67.9863450527 0 800
> [...]
> If I don't specify a selector, I get the messages continuously.
> My e-mail to the mailing list with more details: http://mail-archives.apache.org/mod_mbox/activemq-users/201311.mbox/%3C5277A693.3040906%40fsn.hu%3E
> The sender and the receiver can be seen here:
> http://pastebin.com/vxRtKfGu
> http://pastebin.com/4j5Z9zce
--
This message was sent by Atlassian Jira
(v8.3.4#803005)