anchor.diff:                                  channel=Channel, 
                                   connection=Connection}};
                   {error, Reason} ->
  +                    lager:error("Failure trying to open channel: ~p", [Reason]),
                       {stop, Reason}
               end;
           {error, Reason} ->
  +            lager:error("Failure trying to open connection to URI ~p: ~p", [ConnectionRecord, Reason]),
               {stop, Reason}
       end.
   
  
positive.code:     %% Schedule periodic broadcast.
      schedule_broadcast(),
  
      ConnectionRecord = case os:getenv("RABBITMQ_URI") of
          false ->
              #amqp_params_network{};
          URI ->
  
negative.code:     %% Process connection exits.
      process_flag(trap_exit, true),
  
      %% Initialize membership.
      Myself = myself(),
      {ok, Membership} = ?SET:mutate({add, Myself}, Myself, ?SET:new()),
  