diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 15:36:42 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 15:36:42 +0100 |
| commit | b12423475987f38f3e8105d098cd4c052df1dc5f (patch) | |
| tree | fc15cd6651a01f1744b5064d2e2946777f5ce2a2 | |
| parent | 97da9158e24c914ff0748795b4e49e2f51243170 (diff) | |
| download | rabbitmq-server-b12423475987f38f3e8105d098cd4c052df1dc5f.tar.gz | |
cosmetic
| -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 b7401373..64c7b96a 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -379,7 +379,7 @@ deliver_msgs_to_consumers(Funs = {PredFun, DeliverFun}, FunAcc, acktags = ChAckTags} = ch_record(ChPid), IsMsgReady = PredFun(FunAcc, State), case (IsMsgReady andalso - rabbit_limiter:can_send( Limiter, self(), AckRequired )) of + rabbit_limiter:can_send(Limiter, self(), AckRequired)) of true -> {{Message, IsDelivered, AckTag}, FunAcc1, State1} = DeliverFun(AckRequired, FunAcc, State), |