anchor.diff:          _ ->
               ok
       end,
  -    self() ! heartbeat,
  +    send_info(self(), heartbeat),
       State;
   send_node_event(State, JobId, NodeRef, aborted = Msg) ->
       gen_fsm:send_event(self(), aborted),
  
positive.code:             Error
      end.
  
  send_info(NodeRef, Message) ->
      case pushy_node_state_sup:get_process(NodeRef) of
          Pid when is_pid(Pid) ->
  
negative.code:                   lager:info("No addr ~s for msg: ~p~n", [pushy_tools:bin_to_hex(Addr), NodeRef]),
                    pushy_node_state_sup:get_or_create_process(NodeRef, Addr)
            end,
      send_info(Pid, {raw_message, Message}).
  
  %%
  %% This occurs in the fsm context
  