anchor.diff:  %% Utility functions; we should generalize these and move elsewhere.
   %%
   
  -%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;
  -        {zmq, _Sock, Msg, Opts} ->
  -            ?debugVal(Msg), ?debugVal(Opts),
  -            error
  -    end.
   
   addr_node_map_new() ->
       { dict:new(), dict:new() }.
  
positive.code: handle_cast(_Msg, State) ->
      {noreply, State}.
  
  handle_info({zmq, _CommandSock, Address, [rcvmore]},
              State) ->
      %% TODO: This needs a more graceful way of handling message sequences. I really feel like we need to
      %% abstract out some more generalized routines to handle the message receipt process.
      % error_logger:info_msg("Receiving message with address ~w~n", [Address]),
  
      Header = read_header(),
      Body = pushy_util:read_body(),
  
      % error_logger:info_msg("Received message~n\tA ~p~n\tH ~s~n\tB ~s~n", [Address, Header, Body]),
      State1 = case catch pushy_util:do_authenticate_message(Header, Body) of
  
negative.code:                private_key = PrivateKey},
          Org, Node, Message) ->
      Address = addr_node_map_lookup_by_node(AddrNodeMap, {Org, Node}),
      push_messaging:send_message(CommandSocket, [Address, pushy_util:signed_header_from_message(PrivateKey, Message), Message]).
  
  do_send_multi(#state{addr_node_map = AddrNodeMap,
                       command_sock = CommandSocket,
                       private_key = PrivateKey},
                Org, Nodes, Message) ->
      FrameList = [ pushy_util:signed_header_from_message(PrivateKey, Message), Message],
      AddressList = [addr_node_map_lookup_by_node(AddrNodeMap, {Org, Node}) || Node <- Nodes],
      pushy_messaging:send_message_multi(CommandSocket, AddressList, FrameList).
  
  process_message(State, Address, _Header, Body) ->
      case catch jiffy:decode(Body) of
  