diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-08-25 13:10:43 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-08-25 13:10:43 +0100 |
| commit | 70a6b3d5b5312e704b63750ff0dd27ab2d422134 (patch) | |
| tree | c1f975c11745eb7561f1ecadb129a92c8ca35d81 | |
| parent | 846b176a7c02e245b5580e56900a69e34b691f2f (diff) | |
| download | rabbitmq-server-git-70a6b3d5b5312e704b63750ff0dd27ab2d422134.tar.gz | |
consistent field order
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index 031ca914b1..87de64502b 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -426,8 +426,8 @@ tx_commit(Publishes, MsgsWithAcks, end, Len = length(Publishes), {ok, lose_memory(ASize, State #mqstate - { length = Length + Len, - msg_buf = inc_queue_length(MsgBuf, Len) })}; + { msg_buf = inc_queue_length(MsgBuf, Len), + length = Length + Len })}; tx_commit(Publishes, MsgsWithAcks, State = #mqstate { mode = mixed, queue = Q, msg_buf = MsgBuf, is_durable = IsDurable, length = Length }) -> @@ -503,8 +503,8 @@ requeue(MessagesWithAckTags, State = #mqstate { mode = disk, queue = Q, end, [], MessagesWithAckTags), ok = rabbit_disk_queue:requeue(Q, lists:reverse(Requeue)), Len = length(MessagesWithAckTags), - {ok, State #mqstate { length = Length + Len, - msg_buf = inc_queue_length(MsgBuf, Len) }}; + {ok, State #mqstate { msg_buf = inc_queue_length(MsgBuf, Len), + length = Length + Len }}; requeue(MessagesWithAckTags, State = #mqstate { mode = mixed, queue = Q, msg_buf = MsgBuf, is_durable = IsDurable, |