anchor.diff:  
   -include_lib("eunit/include/eunit.hrl").
   -include_lib("public_key/include/public_key.hrl").
  +-include_lib("pushy_metrics.hrl").
   
   %% TODO : figure out where this really should come from
   -opaque dictionary() :: any().
  
positive.code:          send_multi_command/3]).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Exports
  %% ------------------------------------------------------------------
  
  
negative.code:     {reply, ok, State}.
  
  handle_cast({send, OrgName, NodeName, Message}, #state{}=State) ->
      {noreply, ?TIME_IT(?MODULE, do_send, (State, OrgName, NodeName, Message))};
  handle_cast({send_multi, OrgName, Nodes, Message}, #state{}=State) ->
      {noreply, ?TIME_IT(?MODULE, do_send_multi, (State, OrgName, Nodes, Message))};
  handle_cast(_Msg, State) ->
      {noreply, State}.
  
  handle_info({zmq, CommandSock, Frame, [rcvmore]}, State) ->
      {noreply, ?TIME_IT(?MODULE, do_receive, (CommandSock, Frame, State))};
  handle_info(_Info, State) ->
      {noreply, State}.
  
  terminate(_Reason, _State) ->
      ok.
  
  code_change(_OldVsn, State, _Extra) ->
      {ok, State}.
  
  %% ------------------------------------------------------------------
  %% Internal Function Definitions
  %% ------------------------------------------------------------------
  
  do_receive(CommandSock, Frame, 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]),
  