anchor.diff:      schedule_self_message_delivery(Name, Message, Channel, ?DEFAULT_PARTITION_KEY, PreInterpositionFuns),
       {reply, ok, State};
   
  -handle_call({forward_message, Name, Channel, Clock, PartitionKey, ServerRef, OriginalMessage, Options}=FullMessage, 
  +handle_call({forward_message, Name, Channel, Clock, PartitionKey, ServerRef, OriginalMessage, Options}=_FullMessage, 
               From, 
               #state{pre_interposition_funs=PreInterpositionFuns}=State) ->
       %% lager:info("number of forward_message pre_interposition_funs ~p", [length(dict:to_list(PreInterpositionFuns))]),
  -    lager:info("called: ~p", [FullMessage]),
  +    % lager:info("called: ~p", [FullMessage]),
   
       %% Run all interposition functions.
       DeliveryFun = fun() ->
  
positive.code:                     WrappedMessage =  {forward_message, ServerRef, FullMessage},
                      WrappedOriginalMessage =  {forward_message, ServerRef, OriginalMessage},
  
                      lager:info("NO acknowledge message: ~p, options: ~p", [WrappedMessage, Options]),
  
                      %% Fire post-interposition functions -- trace after wrapping!
                      PostFoldFun = fun(_Name, PostInterpositionFun, ok) ->
  
negative.code:     DeliveryFun = fun() ->
          %% Fire pre-interposition functions.
          PreFoldFun = fun(_Name, PreInterpositionFun, ok) ->
              % lager:info("firing receive_message preinterposition fun for original message: ~p", [OriginalMessage]),
              PreInterpositionFun({receive_message, Peer, OriginalMessage}),
              ok
          end,
  