diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 11:34:29 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 11:34:29 +0000 |
| commit | b5224659d3efcee5ba57b1dc4897a91595db7e4a (patch) | |
| tree | f11706d9844a30f6c0f77ed34c6638478574dd2c /src/rabbit_amqqueue_process.erl | |
| parent | 2f797f1991a6e98cad4a0a85a9580d71542b4858 (diff) | |
| download | rabbitmq-server-b5224659d3efcee5ba57b1dc4897a91595db7e4a.tar.gz | |
A bit more abstraction, plus identities for heartbeater /
queue_collector / limiter.
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 049df840..2c2b747f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -124,7 +124,7 @@ info_keys() -> ?INFO_KEYS. init(Q) -> process_flag(trap_exit, true), - put(rabbit_process_name, {queue, Q#amqqueue.name}), + rabbit_misc:store_identity(queue, Q#amqqueue.name), {ok, init_state(Q#amqqueue{pid = self()}), hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. |