diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-15 14:02:58 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-15 14:02:58 +0000 |
| commit | 4233681bbc79c022e8bf5f2114c407fe2d744fef (patch) | |
| tree | 970704c1f410b3829742f08c113ac841380ed00d /src | |
| parent | 5e1647232f7e6ee3b71fdfd47b083591773e34e8 (diff) | |
| download | rabbitmq-server-git-4233681bbc79c022e8bf5f2114c407fe2d744fef.tar.gz | |
removed reminder comment
There seems to already be a mechanism in place for this.
amqqueue_process:next_state/1 confirms the messages reported by
VQ:drain_confirmed/1, and this seems to work fine for the other cases.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index e6fddd1482..25e5135766 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1201,8 +1201,7 @@ handle_cast({confirm, MsgSeqNos, _From}, {BQS3, UC3} = lists:foldl( fun (MsgSeqNo, {BQS1, UC1}) -> - %% FIXME Forward confirms to channels - {_, BQS2} = + {_Guids, BQS2} = case gb_trees:get(MsgSeqNo, UC1) of {Reason, AckTag} when Reason =:= expired; Reason =:= rejected; |