anchor.diff:                                 routing_key = list_to_binary([ApiKey, <<".named.">>, Name, <<".#">>])},
     #'queue.bind_ok'{} = amqp_channel:call(Channel, QueueBinding),
   
  -  Sub = #'basic.consume'{queue = QueueName, no_ack = True},
  +  Sub = #'basic.consume'{queue = QueueName, no_ack = true},
     #'basic.consume_ok'{consumer_tag = Tag} = amqp_channel:subscribe(Channel, Sub, self()),
     {noreply, State#state{subscriptions=[{QueueName, Tag}|Subscriptions]}};
   handle_cast({join_channel, Name, HandlerSessionId}, State = #state{channel = Channel, api_key = ApiKey}) ->
  
positive.code: %% Resume listening on service bindings
  handle_cast(resume_subs, State = #state{channel = Channel, subscriptions = Subscriptions}) ->
    Subs = lists:map(fun({QueueName, _Tag}) ->
                Sub = #'basic.consume'{queue = QueueName, no_ack = True},
                #'basic.consume_ok'{consumer_tag = NewTag} = amqp_channel:subscribe(Channel, Sub, self()),
                {QueueName, NewTag}
              end, Subscriptions ),
  
negative.code: 
    amqp_channel:register_return_handler(Channel, self()),
  
    Sub = #'basic.consume'{queue = QueueName, no_ack = true},
    #'basic.consume_ok'{} = amqp_channel:subscribe(Channel, Sub, self()),
  
    {reply, ok,
  