diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-09-16 21:00:37 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-09-16 21:00:37 +0100 |
| commit | 1299f4acd0f282967191a7d69b444887e055b603 (patch) | |
| tree | 6be41d8b34f7ed4ff3427e989ba3e3ca6a32fdab | |
| parent | 7da6e5a8fb6e2a712a6397b8fc1c91297bf8f3e8 (diff) | |
| download | rabbitmq-server-git-1299f4acd0f282967191a7d69b444887e055b603.tar.gz | |
cosmetic: slightly more sensible field order
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 734b22911f..d41db65a79 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -56,11 +56,11 @@ -record(consumer, {tag, ack_required}). %% These are held in our process dictionary --record(cr, {consumer_count, - ch_pid, - limiter, +-record(cr, {ch_pid, monitor_ref, acktags, + consumer_count, + limiter, is_limit_active, unsent_message_count}). @@ -336,10 +336,10 @@ ch_record(ChPid) -> Key = {ch, ChPid}, case get(Key) of undefined -> MonitorRef = erlang:monitor(process, ChPid), - C = #cr{consumer_count = 0, - ch_pid = ChPid, + C = #cr{ch_pid = ChPid, monitor_ref = MonitorRef, acktags = sets:new(), + consumer_count = 0, is_limit_active = false, limiter = rabbit_limiter:make_token(), unsent_message_count = 0}, |