anchor.diff:                      {pong, SourceNode, DestinationNode, SourceTime},
                       Connections),
   
  -    {reply, ok, State#state{connections=Connections}};
  +    gen_server:reply(From, ok),
  +
  +    {noreply, State#state{connections=Connections}};
   handle_message({pong, SourceNode, DestinationNode, SourceTime},
  +               From,
                  #state{distance_metrics=DistanceMetrics0}=State) ->
       %% Compute difference.
       ArrivalTime = erlang:timestamp(),
  
positive.code:     {noreply, State};
  
  handle_call({receive_message, Peer, OriginalMessage}, 
              _From, 
              #state{pre_interposition_funs=PreInterpositionFuns,
                     interposition_funs=InterpositionFuns,
                     post_interposition_funs=PostInterpositionFuns} = State) ->
      lager:info("~p: Inside the receive interposition, message from ~p at node ~p", [node(), Peer, node()]),
      lager:info("~p: Count of interposition funs: ~p", [node(), dict:size(InterpositionFuns)]),
  
      %% Fire pre-interposition functions.
      PreFoldFun = fun(_Name, PreInterpositionFun, ok) ->
          PreInterpositionFun({receive_message, Peer, OriginalMessage}),
          ok
      end,
      dict:fold(PreFoldFun, ok, PreInterpositionFuns),
  
      %% Filter messages using interposition functions.
      FoldFun = fun(_Name, InterpositionFun, M) ->
          InterpositionFun({receive_message, Peer, M})
  
negative.code: 
      case Message of
          undefined ->
              gen_server:reply(From, ok),
              {noreply, State};
          _ ->
              handle_message(Message, From, State)
      end;
  
  handle_cast({forward_message, From, Name, Channel, Clock, PartitionKey, ServerRef, OriginalMessage, Options},
              #state{interposition_funs=InterpositionFuns, 
                     post_interposition_funs=PostInterpositionFuns, 
  