anchor.diff:      %% Process connection exits.
       process_flag(trap_exit, true),
   
  -    %% Ensure that the amqp backend is started.
  -    {ok, _} = application:ensure_all_started(amqp_client),
  -
       %% Initialize membership.
       Myself = myself(),
       {ok, Membership} = ?SET:mutate({add, Myself}, Myself, ?SET:new()),
  
positive.code:                                 channel=Channel, 
                                  connection=Connection}};
                  {error, Reason} ->
                      {stop, Reason}
              end;
          {error, Reason} ->
              {stop, Reason}
      end.
  
  
negative.code:     %% Schedule periodic broadcast.
      schedule_broadcast(),
  
      ConnectionRecord = case application:get_env(partisan, amqp_uri, false) of
          false ->
              #amqp_params_network{};
          URI ->
  