[rabbitmq-discuss] RabbitMQ 2.6.1 is unexpectedly eating up memory
ingo schramm
schramm.ingo at googlemail.com
Wed Mar 7 14:26:58 GMT 2012
Today it happened again. When Rabbit had about 13G RAM usage on one node
(<1G is the usual number), I connected to the node and got some infos. I
post these below. Unfortunately, I cannot see that much in the data since I
do not know what the processes are doing exactly inside Rabbit.
After a while the system seemed to recover but irritated clients started to
connect in an unusual pattern and then - almost immediately - the RAM usage
executed a Big Bang, up to 55G allocated, the machine began to swap ...
Here is the dump of the 10 most memory consuming processes.
(ram2 at tarazed)4> erlang:memory().
[{total,14709955672},
{processes,9701451024},
{processes_used,9685449080},
{system,5008504648},
{atom,1318801},
{atom_used,1286285},
{binary,4901053992},
{code,15227889},
{ets,23180616}]
[{{memory,1868315056},
<0.21462.60>,
[{current_function,{erl_eval,do_apply,5}},
{initial_call,{erlang,apply,2}},
{status,running},
{message_queue_len,0},
{messages,[]},
{links,[<0.21461.60>]},
{dictionary,[]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<18922.32.0>},
{total_heap_size,233539280},
{heap_size,116769640},
{stack_size,88},
{reductions,8019756},
{garbage_collection,[{fullsweep_after,65535},{minor_gcs,1}]},
{suspending,[]}]},
{{memory,1826853040},
<0.252.0>,
[{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,3},
{messages,[{'$gen_cast',{notify_sent,<0.26233.60>}},
{'$gen_cast',{ack,[128755027],<0.22877.60>}},
{'$gen_cast',{unblock,<0.22877.60>}}]},
{links,[#Port<0.162932>,<0.250.0>,#Port<0.4466>]},
{dictionary,[{{ch,<0.30314.59>},
{cr,1,<0.30314.59>,
{token,<0.30313.59>,true},
#Ref<0.0.913.261747>,
{set,1,16,16,8,80,...},
true,1}},
{{ch,<0.11679.60>},
{cr,1,<0.11679.60>,
{token,<0.11678.60>,true},
#Ref<0.0.916.161564>,
{set,1,16,16,8,...},
true,0}},
{{ch,<0.29890.59>},
{cr,1,<0.29890.59>,
{token,<0.29889.59>,true},
#Ref<0.0.913.256520>,
{set,1,16,16,...},
true,1}},
{{ch,<0.24130.59>},
{cr,1,<0.24130.59>,
{token,<0.24129.59>,true},
#Ref<0.0.912.149255>,
{set,1,16,...},
true,1}},
{{ch,<0.21656.59>},
{cr,1,<0.21656.59>,
{token,<0.21655.59>,true},
#Ref<0.0.911.188523>,
{set,1,...},
true,1}},
{{ch,<0.15601.60>},
{cr,1,<0.15601.60>,
{token,<0.15600.60>,true},
#Ref<0.0.917.100808>,
{set,...},
true,...}},
{{ch,<15215.21015.63>},
{cr,1,<15215.21015.63>,
{token,<15215.21014.63>,...},
#Ref<0.0.815.242631>,{...},...}},
{{ch,<0.21015.12>},
{cr,1,<0.21015.12>,{token,...},#Ref<0.0.295.125075>,...}},
{{ch,<0.17432.59>},{cr,1,<0.17432.59>,{...},...}},
{{ch,<0.9598.46>},{cr,1,<0.9598.46>,...}},
{{ch,<15215.20479.63>},{cr,1,...}},
{{ch,<0.24362.59>},{cr,...}},
{{ch,...},{...}},
{{...},...},
{...}|...]},
{trap_exit,true},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,228065700},
{heap_size,228065700},
{stack_size,48},
{reductions,86360443586},
{garbage_collection,[{fullsweep_after,65535},{minor_gcs,0}]},
{suspending,[]}]},
{{memory,544009512},
<0.218.0>,
[{registered_name,delegate_11},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,45210},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,67810415},
{heap_size,8024355},
{stack_size,32},
{reductions,536435169},
{garbage_collection,[{fullsweep_after,65535},{minor_gcs,1}]},
{suspending,[]}]},
{{memory,544003272},
<0.213.0>,
[{registered_name,delegate_6},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,45000},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_call',{<15215.4753.67>,
{#Ref<15215.0.573.141891>,ram2 at tarazed}},
{invoke,#Fun<rabbit_amqqueue.22.114209891>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,67810415},
{heap_size,8024355},
{stack_size,32},
{reductions,492300563},
{garbage_collection,[{fullsweep_after,65535},
{minor_gcs,...}]},
{suspending,[]}]},
{{memory,543937016},
<0.220.0>,
[{registered_name,delegate_13},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,43117},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,67810415},
{heap_size,8024355},
{stack_size,32},
{reductions,516829717},
{garbage_collection,[{fullsweep_after,...},{...}]},
{suspending,[]}]},
{{memory,509272344},
<0.208.0>,
[{registered_name,delegate_1},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,36921},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_amqqueue.23.2473037>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,63501410},
{heap_size,15672560},
{stack_size,32},
{reductions,481258527},
{garbage_collection,[{...}|...]},
{suspending,[]}]},
{{memory,484092056},
<0.209.0>,
[{registered_name,delegate_2},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,33987},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,60366900},
{heap_size,12538050},
{stack_size,32},
{reductions,439896730},
{garbage_collection,[...]},
{suspending,...}]},
{{memory,383857832},
<0.207.0>,
[{registered_name,delegate_0},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,36015},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[<0.252.0>]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,47828850},
{heap_size,47828850},
{stack_size,32},
{reductions,464166560},
{garbage_collection,...},
{...}]},
{{memory,322186712},
<0.214.0>,
[{registered_name,delegate_7},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,25955},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,[...]}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,7}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,40160935},
{heap_size,15672560},
{stack_size,32},
{reductions,...},
{...}|...]},
{{memory,245833600},
<0.212.0>,
[{registered_name,delegate_5},
{current_function,{gen,wait_resp_mon,3}},
{initial_call,{proc_lib,init_p,5}},
{status,waiting},
{message_queue_len,27354},
{messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{ram2 at tarazed,...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
[{...}]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
{'$gen_cast',{invoke,...}},
{'$gen_cast',{...}},
{'$gen_cast',...},
{...}|...]},
{links,[<0.206.0>]},
{dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
<0.109.0>]},
{'$initial_call',{gen,init_it,...}}]},
{trap_exit,false},
{error_handler,error_handler},
{priority,normal},
{group_leader,<0.108.0>},
{total_heap_size,30610465},
{heap_size,30610465},
{stack_size,...},
{...}|...]}]
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on
> 2.7.1, but for 2.6.1 you could check per-queue memory use with
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120307/3d4ef029/attachment.htm>
More information about the rabbitmq-discuss
mailing list