anchor.diff:  %% @private
   do_send_message(Message, Channel) ->
       lager:info("Sending broadcast: ~p", [Message]),
  -    BroadcastName = <<"broadcast">>,
  +    BroadcastName = ?BROADCAST,
       Payload = term_to_binary(Message),
       Publish = #'basic.publish'{exchange = BroadcastName},
       amqp_channel:cast(Channel, Publish, #amqp_msg{payload = Payload}),
  
positive.code: 
  %% @private
  gen_broadcast_exchanges_channels_bindings(Channel) ->
      BroadcastName = <<"broadcast">>,
  
      ExchangeDeclare = #'exchange.declare'{exchange = BroadcastName, type = <<"fanout">>},
      #'exchange.declare_ok'{} = amqp_channel:call(Channel, ExchangeDeclare),
  
negative.code:     {noreply, State}.
  
  handle_info(broadcast, #state{channel=Channel, membership=Membership0}=State) ->
      Membership = ?SET:query(Membership0),
  
      %% Open direct exchanges and default channels.
      lists:foreach(fun(Node) ->
  