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 | 5d8c0b95e620dcd90c743767e2c16866a1ece3d8 (patch) | |
| tree | fc15cd6651a01f1744b5064d2e2946777f5ce2a2 /src | |
| parent | 7fe53bc472e3fdefeb009b1d3093e2c6ed5e2a2a (diff) | |
| download | rabbitmq-server-git-5d8c0b95e620dcd90c743767e2c16866a1ece3d8.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -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 b740137372..64c7b96a29 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), |