anchor.diff:  %% Utility functions; we should generalize these and move elsewhere.
   %%
   
  -read_address_separator() ->
  -    receive
  -        {zmq, _Sock, <<>>, [rcvmore]} ->
  -            ok
  -    end.
  +%read_address_separator() ->
  +%    receive
  +%        {zmq, _Sock, <<>>, [rcvmore]} ->
  +%            ok;
  +%        {zmq, _Sock, Msg, Opts} ->
  +%            ?debugVal(Msg), ?debugVal(Opts),
  +%            error
  +%    end.
   
   read_header() ->
       receive
           {zmq, _Sock, HeaderFrame, [rcvmore]} ->
  -            HeaderFrame
  +            HeaderFrame;
  +        {zmq, _Sock, Msg, Opts} ->
  +            ?debugVal(Msg), ?debugVal(Opts),
  +            error
       end.
  -
   
   addr_node_map_new() ->
       { dict:new(), dict:new() }.
   
   kill_crossref(Forward, Backward, Key) ->
  +    ?debugVal(Forward),
  +    ?debugVal(Backward),
       case dict:find(Forward, Key) of
           {ok, OldValue} ->
               dict:erase(OldValue, Backward);
  
positive.code: handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  
  handle_cast({send, ClientName, Message}, #state{}=State) ->
      do_send(State, ClientName, Message),
      {noreply, State};
  handle_cast({send_multi, ClientName, Message}, #state{}=State) ->
      do_send_multi(State, ClientName, Message),
      {noreply, State};
  handle_cast(_Msg, State) ->
      {noreply, State}.
  
  handle_info({zmq, _CommandSock, Address, [rcvmore]},
              State) ->
      read_address_separator(),
      Header = read_header(),
      Body = pushy_util:read_body(),
      State1 = case catch pushy_util:do_authenticate_message(Header, Body) of
                   ok ->
                       process_message(State, Address, Header, Body);
  
negative.code: start_link(Ctx) ->
      gen_server:start_link({local, ?SERVER}, ?MODULE, [Ctx], []).
  
  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
  