anchor.diff:      State#state{membership=Membership};
   handle_message({forward_message, ServerRef, Message}, State) ->
       ServerRef ! Message,
  -    {reply, ok, State}.
  +    State.
   
   %% @private
   members(Membership) ->
  
positive.code: gen_unicast_subscription(Node, Channel) ->
      UnicastName = gen_unicast_name(Node),
  
      Sub = #'basic.consume'{queue = UnicastName},
      #'basic.consume_ok'{consumer_tag = _Tag} = amqp_channel:call(Channel, Sub),
  
  
negative.code:     ok.
  
  %% @private
  gen_broadcast_subscription(Node, Channel) ->
      UnicastName = gen_unicast_name(Node),
  
      %% Subscribe to our queue served by fanout exchange.
      Sub = #'basic.consume'{queue = UnicastName},
      #'basic.consume_ok'{consumer_tag = _Tag} = amqp_channel:call(Channel, Sub),
  
      ok.
  