anchor.diff:              case amqp_connection:open_channel(Connection) of
                   {ok, Channel} ->
                       ok = gen_unicast_exchanges_channels_bindings(Myself, Channel),
  -                    ok = gen_broadcast_exchanges_channels_bindings(Channel),
  +                    ok = gen_broadcast_exchanges_channels_bindings(Myself, Channel),
   
                       ok = gen_unicast_subscription(Myself, Channel),
  -                    ok = gen_broadcast_subscription(Channel),
  +                    ok = gen_broadcast_subscription(Myself, Channel),
   
                       {ok, #state{myself=Myself,
                                   membership=Membership,
  
positive.code:     State#state{membership=Membership};
  handle_message({forward_message, ServerRef, Message}, State) ->
      ServerRef ! Message,
      {reply, ok, State}.
  
  %% @private
  members(Membership) ->
  
negative.code: gen_unicast_subscription(Node, Channel) ->
      UnicastName = gen_unicast_name(Node),
  
      %% Subscribe to our queue / direct exchange for messages.
      Sub = #'basic.consume'{queue = UnicastName},
      #'basic.consume_ok'{consumer_tag = _Tag} = amqp_channel:call(Channel, Sub),
  
  