diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-07 15:29:42 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-07 15:29:42 +0000 |
| commit | b8081c680b9557e52a5dd58a3ef43acc0fcae5f7 (patch) | |
| tree | e9c6c8b1351c8e9442a490d895e362c54f026514 /src | |
| parent | 5e8643f947be0e0eb07a7a1eff9b8cdbbc58f27c (diff) | |
| download | rabbitmq-server-git-b8081c680b9557e52a5dd58a3ef43acc0fcae5f7.tar.gz | |
unbreak variable queue assertions
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 3e34684863..6174daa849 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -589,7 +589,8 @@ dropwhile(Pred, MsgFun, State) -> case Pred(MsgProps) of true -> State2 = MsgFun(read_msg_callback(MsgStatus), State1), - dropwhile(Pred, MsgFun, State2); + {_, State3} = internal_fetch(false, MsgStatus, State2), + dropwhile(Pred, MsgFun, State3); false -> a(in_r(MsgStatus, State1)) end @@ -605,7 +606,6 @@ fetch(AckRequired, State) -> {MsgStatus1, State2} = read_msg(MsgStatus, State1), {Res, State3} = internal_fetch(AckRequired, MsgStatus1, State2), {Res, a(State3)} - end. read_msg_callback(#msg_status { msg = undefined, |