diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-12-17 11:54:27 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-12-17 11:54:27 +0000 |
| commit | cb05332ae9ed6744d7edfc7c83845b569b59a7b4 (patch) | |
| tree | 539179f06028892bb50e5ad3d2fc5dea7e7697d6 | |
| parent | 5f9456cd2db7077fe368a16412f5fc6d8d3cb54c (diff) | |
| download | rabbitmq-server-git-cb05332ae9ed6744d7edfc7c83845b569b59a7b4.tar.gz | |
Whitespace
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index ffff464dc8..922cb6cbcd 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -588,8 +588,8 @@ deliver_or_enqueue(Delivery = #delivery{message = Message}, end end. -publish_max(#delivery{message = Message, - sender = SenderPid}, +publish_max(#delivery{message = Message, + sender = SenderPid}, Props, Delivered, State = #q{backing_queue = BQ, backing_queue_state = BQS, max_depth = undefined}) -> @@ -602,7 +602,7 @@ publish_max(#delivery{message = Message, State = #q{backing_queue = BQ, backing_queue_state = BQS, dlx = XName, - max_depth = MaxDepth }) -> + max_depth = MaxDepth}) -> {Depth, Len} = {BQ:depth(BQS), BQ:len(BQS)}, case {Depth >= MaxDepth, Len =:= 0} of {false, _} -> |