activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Attila Nagy (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQ-4846) Using a selector on a virtual topic's consumer queue makes dispatching very slow
Date Tue, 05 Nov 2013 14:21:19 GMT
Attila Nagy created AMQ-4846:
--------------------------------

             Summary: 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


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
(v6.1#6144)

Mime
View raw message