[openamq-dev] amq_server message limit

[Pieter Hintjens]

Dmitry,

> >  Here is a portion of alert log file. It shows new trace for queue limits
>  > that I added to a server.
>  >  You can see when "slow" client connects (cnn=8) and declares a queue
>  > (que=6) and new queue limits... but messages rapidly grow to 100+ K till I
>  > kill it.

I think you have hit a bug in the queue limit algorithm, triggered by
a specific configuration.

Here is a patch to amq_queue.icl which reports the actual limits per queue:

---- snip ----
Index: amq_queue.icl
===================================================================
@@ -660,6 +659,11 @@
                 //  testing limits until the queue size has exceeded this.
                 if (self->limit_min > limit_value)
                     self->limit_min = limit_value;
+
+                if (amq_server_config_debug_queue (amq_server_config))
+                    smt_log_print (amq_broker->debug_log,
+                        "Q: setlimit queue=%s limit=%d action=%s",
+                        self->name, limit_value, action_text);
             }
             else {
                 smt_log_print (amq_broker->alert_log,
---- snip ----

You'd need to rebuild and run the broker with "--debug_queue 1" in the
production environment where the problem occurs.

If you could tell me what limits are being applied, I'll have more
chance to reproduce the case.

BTW, the duplicate message issue has been fixed, will be in the next
release.  It affected the topic and headers exchange.

Cheers,
Pieter