anchor.diff:  -record(state,
           {command_sock,
            addr_node_map :: {dictionary(), dictionary()},
  -         private_key
  +         private_key,
  +         job
           }).
   
   %% ------------------------------------------------------------------
  
positive.code:     do_send(State, OrgName, NodeName, Message),
      {noreply, State};
  handle_cast({send_multi, OrgName, Nodes, Message}, #state{}=State) ->
      do_send_multi(State, OrgName, Nodes, Message),
      {noreply, State};
  handle_cast(_Msg, State) ->
      {noreply, State}.
  
  
negative.code: do_send_multi(State, Org, Nodes, Message) ->
      [ do_send(State, Org, Node, Message) || Node <- Nodes ].
  
  ack(State, OrgName, Nodes) ->
      Host = pushy_util:get_env(pushy, server_name, fun is_list/1),
      Message = jiffy:encode({[{server, list_to_binary(Host)},
                  {type, <<"ack">>}]}),
      do_send_multi(State, OrgName, Nodes, Message).
  
  
  process_message(#state{job=Job}=State, Address, _Header, Body) ->
      case catch jiffy:decode(Body) of
          {Data} ->
              Type = ej:get({<<"type">>}, Data ),
  