gistfile1.erl

consumer_monitor(ConsumerTag,
                 State = #ch{consumer_mapping = ConsumerMapping,
                             queue_monitors   = QMons,
                             queue_consumers  = QCons,
                             capabilities     = Capabilities}) ->
    case rabbit_misc:table_lookup(
           Capabilities, <<"consumer_cancel_notify">>) of
        {bool, true} ->
            #amqqueue{pid = QPid} = dict:fetch(ConsumerTag, ConsumerMapping),
            QCons1 = dict:update(QPid,
                                 fun (CTags) ->
                                         gb_sets:insert(ConsumerTag, CTags)
                                 end,
                                 gb_sets:singleton(ConsumerTag),
                                 QCons),
            State#ch{queue_monitors  = pmon:monitor(QPid, QMons),
                     queue_consumers = QCons1};
        _ ->
            State
    end.