anchor.diff:  
   %% @private
   do_send_message(Name, Message, Channel) ->
  -    lager:info("Sending message to ~p: ~p", [Name, Message]),
       UnicastName = gen_unicast_name(Name),
       Payload = term_to_binary(Message),
       Publish = #'basic.publish'{exchange = UnicastName, routing_key = UnicastName},
  
positive.code:     %% Schedule periodic broadcast.
      schedule_broadcast(),
  
      URI = case os:getenv("RABBITMQ_URI") of
          false ->
              {stop, no_uri};
          V ->
              V
      end,
      
      {ok, ParsedURI} = amqp_uri:parse(URI),
  
      case amqp_connection:start(ParsedURI) of
          {ok, Connection} ->
              case amqp_connection:open_channel(Connection) of
                  {ok, Channel} ->
  
negative.code: 
  %% @private
  do_send_message(Message, Channel) ->
      BroadcastName = ?BROADCAST,
      Payload = term_to_binary(Message),
      Publish = #'basic.publish'{exchange = BroadcastName},
  