diff options
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; |