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