anchor.diff:  start_link(Ctx) ->
       gen_server:start_link({local, ?SERVER}, ?MODULE, [Ctx], []).
   
  -send_command(ClientName, Message) ->
  -    gen_server:cast(?MODULE, {send, ClientName, Message}).
  -send_multi_command(Clients, Message) ->
  -    gen_server:cast(?MODULE, {send_multi, Clients, Message}).
  +send_command(OrgName, NodeName, Message) ->
  +    gen_server:cast(?MODULE, {send, OrgName, NodeName, Message}).
  +send_multi_command(OrgName, Nodes, Message) ->
  +    gen_server:cast(?MODULE, {send_multi, OrgName, Nodes, Message}).
   
   %% ------------------------------------------------------------------
   %% gen_server Function Definitions
  
positive.code: %% Utility functions; we should generalize these and move elsewhere.
  %%
  
  read_address_separator() ->
      receive
          {zmq, _Sock, <<>>, [rcvmore]} ->
              ok
      end.
  
  read_header() ->
      receive
          {zmq, _Sock, HeaderFrame, [rcvmore]} ->
              HeaderFrame
      end.
  
  
  addr_node_map_new() ->
      { dict:new(), dict:new() }.
  
  kill_crossref(Forward, Backward, Key) ->
      case dict:find(Forward, Key) of
          {ok, OldValue} ->
              dict:erase(OldValue, Backward);
  
negative.code: handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  
  handle_cast({send, OrgName, NodeName, Message}, #state{}=State) ->
      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}.
  
  handle_info({zmq, _CommandSock, Address, [rcvmore]},
              State) ->
      error_logger:info_msg("Receiving message with address ~w~n", [Address]),
  
      Header = read_header(),
      ?debugVal(Address),
      ?debugVal(Header),
      Body = pushy_util:read_body(),
      ?debugVal(Body),
  
      error_logger:info_msg("Received message with address ~p~n~p~n~p~n", [Address, Header, Body]),
      State1 = case catch pushy_util:do_authenticate_message(Header, Body) of
                   ok ->
                       process_message(State, Address, Header, Body);
  