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 | 46431087377e779f61a0478ca8e930fd42eaeafa (patch) | |
| tree | 9621ed056dc258830d58bbba089342244754f23a /src | |
| parent | 6363b121d916793e7ac6122073e1f9c65a50a619 (diff) | |
| download | rabbitmq-server-git-46431087377e779f61a0478ca8e930fd42eaeafa.tar.gz | |
Defensive programming
Diffstat (limited to 'src')
| -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 f9315c5dff..c346292954 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)) |