[openamq-dev] amq_server message limit

[Dmitri Tsyganov]

Hello,

I have few slow client appluications, connecting to my amq_server. They 
are in development and probably run in debug mode.

I try to control memory on my amq server via queue profile settings in 
amq_server.cfg below:
...
 <queue_profile name = "private">
        <limit name = "warn" value = "10000" />
        <limit name = "trim" value = "30000" />
        <limit name = "kill" value = "50000" />
    </queue_profile>

    <queue_profile name = "shared">
        <limit name = "warn" value = "10000" />
        <limit name = "drop" value = "30000" />
        <limit name = "kill" value = "50000" />
    </queue_profile>
...
I've seen this working on one of my dev amq_servers, but on few other 
machine I see messages in a queue grow way beyond the limits.

I see that queue limits checked in amq_queue_basic_publish. Is this the 
only place messages can get into a queue?

Could you think of a reason why this message trimming/dropping logic 
sometimes does not work?
Is it possible that the profile section of the configuration file 
sometimes skipped? Can I check profiles settings on a running server?

Thank you,

Dmitri

Here is a section from alert log that shows queue messages grow:

2008-03-31 11:00:43: I: cnn=26 msg=18 mem=16K/0K exc=8 que=18 csm=20 
bnd=35 adx=7 idx=8 map=7
2008-03-31 11:00:43: I: qcn=20 cnq=20
2008-03-31 11:00:58: I: cnn=26 msg=7837 mem=1982K/0K exc=8 que=18 csm=20 
bnd=35 adx=7 idx=8 map=7
2008-03-31 11:00:58: I: qcn=20 cnq=20
2008-03-31 11:01:13: I: cnn=26 msg=8454 mem=2133K/0K exc=8 que=18 csm=20 
bnd=35 adx=7 idx=8 map=7
2008-03-31 11:01:13: I: qcn=20 cnq=20
2008-03-31 11:01:14: W: client heartbeat slowing (172.26.121.13:38764, 
OpenAMQ Kernel Client, 1.2c4, guest)
2008-03-31 11:01:28: I: cnn=26 msg=10562 mem=2662K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:01:28: I: qcn=20 cnq=20
2008-03-31 11:01:43: I: cnn=26 msg=23239 mem=5845K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:01:43: I: qcn=20 cnq=20
2008-03-31 11:01:58: I: cnn=26 msg=42000 mem=10551K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:01:58: I: qcn=20 cnq=20
2008-03-31 11:02:13: I: cnn=26 msg=58364 mem=14656K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:02:13: I: qcn=20 cnq=20
2008-03-31 11:02:28: I: cnn=26 msg=80144 mem=20125K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:02:28: I: qcn=20 cnq=20
2008-03-31 11:02:43: I: cnn=26 msg=96852 mem=24323K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:02:43: I: qcn=20 cnq=20
2008-03-31 11:02:58: I: cnn=26 msg=118188 mem=29678K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:02:58: I: qcn=20 cnq=20
2008-03-31 11:03:13: I: cnn=26 msg=121261 mem=30452K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:03:13: I: qcn=20 cnq=20
2008-03-31 11:03:28: I: cnn=26 msg=135001 mem=33896K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:03:28: I: qcn=20 cnq=20
2008-03-31 11:03:43: I: cnn=26 msg=153984 mem=38659K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:03:43: I: qcn=20 cnq=20
2008-03-31 11:03:58: I: cnn=26 msg=174474 mem=43796K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:03:58: I: qcn=20 cnq=20
2008-03-31 11:04:13: I: cnn=26 msg=193984 mem=48691K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:04:13: I: qcn=20 cnq=20
2008-03-31 11:04:28: I: cnn=26 msg=211139 mem=53001K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:04:28: I: qcn=20 cnq=20
2008-03-31 11:04:43: I: cnn=26 msg=225862 mem=56689K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:04:43: I: qcn=20 cnq=20
2008-03-31 11:04:58: I: cnn=26 msg=244844 mem=61448K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:04:58: I: qcn=20 cnq=20
2008-03-31 11:05:00: W: client heartbeat slowing (172.26.121.13:38793, 
OpenAMQ Kernel Client, 1.2c4, guest)
2008-03-31 11:05:13: I: cnn=26 msg=271204 mem=68065K/0K exc=8 que=18 
csm=20 bnd=35 adx=7 idx=8 map=7
2008-03-31 11:05:13: I: qcn=20 cnq=20
2008-03-31 11:05:17: W: client heartbeat slowing (172.26.121.13:38779, 
OpenAMQ Kernel Client, 1.2c4, guest)
2008-03-31 11:05:17: W: client heartbeat slowing (172.26.121.13:38784, 
OpenAMQ Kernel Client, 1.2c4, guest)