anchor.diff:  addr_node_map_lookup_by_node({_, NodeToAddr}, Node) ->
       dict:fetch(Node, NodeToAddr).
   
  -send_multipart(Socket, Address, Message) ->
  -    erlzmq:send(Socket, Address, [sndmore]),
  -    %erlzmq:send(Socket, <<>>, [sndmore]),
  -    send_multipart(Socket, Message).
  -
  -send_multipart(_Socket, []) ->
  -    ok;
  -send_multipart(Socket, [Msg | []]) ->
  -    erlzmq:send(Socket, Msg, []);
  -send_multipart(Socket, [Head | Tail]) ->
  -    erlzmq:send(Socket, Head, [sndmore]),
  -    send_multipart(Socket, Tail).
  +
  
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
  