anchor.diff:  
   
   get_node_ref(Data) ->
  -    % This essentially debug code.
  +    %% This essentially debug code.
       _ClientName = ej:get({<<"client">>}, Data),
       OrgName  = ej:get({<<"org">>}, Data),
       NodeName = ej:get({<<"node">>}, Data),
  
positive.code:             State1 = try ?TIME_IT(pushy_messaging, parse_message, (Address, Header, Body, KeyFetch)) of
                           {ok, #pushy_message{} = Msg} ->
                               process_message(State, Msg);
                   {error, #pushy_message{validated=bad_sig}} ->
                               lager:error("Command message failed verification: header=~s", [Header]),
                               State
                       catch
                   error:Error ->
                               Stack = erlang:get_stacktrace(),
                               lager:error("Command message parser failed horribly: header=~w~nstack~s", [Error, Stack]),
                               State;
  
negative.code: addr_node_map_update(#state{addr_node_map = AddrNodeMap} = State, Addr, Node) ->
      State#state{addr_node_map = addr_node_map_update(AddrNodeMap, Addr, Node)};
  addr_node_map_update({AddrToNode, NodeToAddr}, Addr, Node) ->
      %% purge any old references
      NodeToAddr1 = kill_crossref(AddrToNode, NodeToAddr, Addr),
      AddrToNode1 = kill_crossref(NodeToAddr, AddrToNode, Node),
      { dict:store(Addr, Node, AddrToNode1),
  