anchor.diff:                    },
       {ok, State}.
   
  -handle_call({send, Method, NodeRef, Message}, _From, #state{}=State) ->
  -    NState = ?TIME_IT(?MODULE, do_send, (State, Method, NodeRef, Message)),
  -    {reply, ok, NState};
  -handle_call({send_multi, Method, NodeRefs, Message}, _From, #state{}=State) ->
  -    NState = ?TIME_IT(?MODULE, do_send_multi, (State, Method, NodeRefs, Message)),
  +handle_call({send_raw, Message}, _From, #state{}=State) ->
  +    NState = ?TIME_IT(?MODULE, do_send_raw, (State, Message)),
       {reply, ok, NState};
   handle_call(_Request, _From, State) ->
       {reply, ok, State}.
  
positive.code: start_link(PushyState) ->
      gen_server:start_link({local, ?SERVER}, ?MODULE, [PushyState], []).
  
  -spec send_command(node_ref(), ejson()) -> ok.
  send_command(NodeRef, Message) when is_tuple(NodeRef) ->
      gen_server:call(?MODULE, {send, hmac_sha256, NodeRef, Message});
  %%% A good optimization is to use HMAC when the number of nodes is small.
  %%% We should do more work to determine exactly where the crossover point between doing a
  %%% single expensive signature vs many cheap HMAC signatures. The number is somewhere between
  %%% 100 and 1000.
  send_command(NodeRefs, Message) when is_list(NodeRefs)
                                       andalso length(NodeRefs) < ?PUSHY_MULTI_SEND_CROSSOVER ->
      gen_server:call(?MODULE, {send_multi, hmac_sha256, NodeRefs, Message});
  send_command(NodeRefs, Message) when is_list(NodeRefs)  ->
      gen_server:call(?MODULE, {send_multi, rsa2048_sha1, NodeRefs, Message}).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Definitions
  
negative.code:     %% 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.
      case pushy_messaging:receive_message_async(CommandSock, Frame) of
          [_Address, _Header, _Body] = Message->
              pushy_node_state:recv_msg(Message),
              State;
          _Packets ->
              lager:debug("Received runt/overlength message with ~n packets~n", [length(_Packets)]),
              State
  