anchor.diff:                            connections=Connections}};
   
   handle_info(retransmit, #state{pre_interposition_funs=PreInterpositionFuns}=State) ->
  -    RetransmitFun = fun({_, {forward_message, From, Name, Channel, Clock, PartitionKey, ServerRef, Message, _Options}}) ->
  +    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]),
   
  
positive.code:                     FullMessage = case partisan_config:get(binary_padding, false) of
                          true ->
                              BinaryPadding = partisan_config:get(binary_padding_term, undefined),
                              {forward_message, Name, Channel, Clock, PartitionKey, ServerRef, {'$partisan_padded', BinaryPadding, Message}, Options};
                          false ->
                              {forward_message, Name, Channel, Clock, PartitionKey, ServerRef, Message, Options}
                      end,
  
                      case FastForward of
  
negative.code:         dict:fold(PreFoldFun, ok, PreInterpositionFuns),
  
          %% Once pre-interposition returns, then schedule for delivery.
          gen_server:cast(?MODULE, {forward_message, undefined, Name, Channel, undefined, PartitionKey, ?MODULE, Message, Options})
      end,
  
      case partisan_config:get(replaying, false) of 
  