anchor.diff:      addr_node_map_lookup_by_addr(AddrNodeMap, Node);
   addr_node_map_lookup_by_node({_, NodeToAddr}, Node) ->
       dict:fetch(Node, NodeToAddr).
  -
  -
  
positive.code: 
  -include("pushy.hrl").
  -include_lib("pushy_common/include/pushy_metrics.hrl").
  
  %% TODO : figure out where this really should come from
  -opaque dictionary() :: any().
  
negative.code:     State.
  
  %% FIX: Take advantage of multiple function heads to make code easier to read
  process_message(State, #pushy_message{address=Address, body=Data}) ->
      {State2, NodeRef} = get_node_ref(State, Address, Data),
      JobId = ej:get({<<"job_id">>}, Data),
      Type = ej:get({<<"type">>}, Data),
      send_node_event(JobId, NodeRef, Type),
      State2.
  
  send_node_event(JobId, NodeRef, <<"heartbeat">>) ->
      lager:debug("Received heartbeat for node ~p with job id ~p", [JobId, NodeRef]),
  