diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-05-21 18:15:21 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-05-21 18:15:21 +0100 |
| commit | f4a4d7520cc2ddfe39d21b3fc6c70a39e41d423d (patch) | |
| tree | 617116b6bc45a7e477979c760473dd777a3e0f80 | |
| parent | 809d0768693f6a8b5218874848ef7c3e439a9840 (diff) | |
| download | rabbitmq-server-git-f4a4d7520cc2ddfe39d21b3fc6c70a39e41d423d.tar.gz | |
just a couple more comments / TODO items.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 5e94134623..bcf4dae474 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -350,7 +350,7 @@ handle_ch_down(DownPid, State = #q{exclusive_consumer = Holder, erase({ch, ChPid}), case check_auto_delete( deliver_or_requeue_n( - [Message || + [Message || %% TODO NEED TO GRAB ACKTAGS OUT OF HERE AND PASS THEM THROUGH {_Messsage_id, Message} <- dict:to_list(UAM)], State#q{ exclusive_consumer = case Holder of @@ -722,7 +722,7 @@ handle_cast({requeue, MsgIds, ChPid}, State) -> [ChPid]), noreply(State); C = #cr{unacked_messages = UAM} -> - {Messages, NewUAM} = collect_messages(MsgIds, UAM), + {Messages, NewUAM} = collect_messages(MsgIds, UAM), %% TODO Messages must contain AckTags too store_ch_record(C#cr{unacked_messages = NewUAM}), noreply(deliver_or_requeue_n(Messages, State)) end; |