diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-12-18 17:34:11 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-12-18 17:34:11 +0000 |
| commit | 18045c8bd27a9967e4024dda79f05b35edab30d1 (patch) | |
| tree | 84ff9bd62faaf41cccca84cb11d5b19a6b5d6b32 | |
| parent | 9e51c84f93f5c08d3e9c90b49ca744d29b32e50e (diff) | |
| download | rabbitmq-server-git-18045c8bd27a9967e4024dda79f05b35edab30d1.tar.gz | |
Inline
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 01125819ea..933c40296f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -598,8 +598,7 @@ publish_max(#delivery{message = Message, Props, Delivered, #q{backing_queue = BQ, backing_queue_state = BQS, max_depth = MaxDepth}) -> - {Depth, Len} = {BQ:depth(BQS), BQ:len(BQS)}, - case {Depth >= MaxDepth, Len =:= 0} of + case {BQ:depth(BQS) >= MaxDepth, BQ:len(BQS) =:= 0} of {false, _} -> BQ:publish(Message, Props, Delivered, SenderPid, BQS); {true, true} -> |