anchor.diff:  
       %% Transmit outgoing messages.
       lists:foreach(fun({Peer, Message}) ->
  -        schedule_message_delivery(Peer, Message, ?MEMBERSHIP_PROTOCOL_CHANNEL, ?DEFAULT_PARTITION_KEY, PreInterpositionFuns)
  +        schedule_self_message_delivery(Peer, Message, ?MEMBERSHIP_PROTOCOL_CHANNEL, ?DEFAULT_PARTITION_KEY, PreInterpositionFuns)
       end, OutgoingMessages),
   
       case partisan_config:get(connect_disterl) of 
  
positive.code:             partisan_util:process_forward(ServerRef, Message)
      end,
  
      gen_server:reply(From, ok),
  
      {noreply, State};
  
  
negative.code:                           connections=Connections}};
  
  handle_info(retransmit, #state{pre_interposition_funs=PreInterpositionFuns}=State) ->
      RetransmitFun = fun({_, {forward_message, From, Name, Channel, Clock, PartitionKey, ServerRef, Message, Options}}) ->
          Mynode = partisan_peer_service_manager:mynode(),
          lager:info("~p no acknowledgement yet, restranmitting message ~p with clock ~p to ~p", [Mynode, Message, Clock, Name]),
  
  