diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2012-04-19 13:28:03 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2012-04-19 13:28:03 +0100 |
| commit | 09151103684bd5e76e5b3196d1faa70a2aadcee5 (patch) | |
| tree | 9621ed056dc258830d58bbba089342244754f23a | |
| parent | 423e12d4f72380e60ec0dac06b809fd29c9f41d0 (diff) | |
| download | rabbitmq-server-09151103684bd5e76e5b3196d1faa70a2aadcee5.tar.gz | |
Defensive programming
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index f9315c5d..c3462929 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -592,7 +592,7 @@ dropwhile(Pred, MsgFun, State) -> {MsgStatus1, State2} = read_msg(MsgStatus, State1), {{Msg, _, AckTag, _}, State3} = internal_fetch(true, MsgStatus1, State2), - MsgFun(Msg, AckTag), + ok = MsgFun(Msg, AckTag), dropwhile(Pred, MsgFun, State3); {false, _} -> a(in_r(MsgStatus, State1)) |