anchor.diff:  -include_lib("pushy_common/include/pushy_metrics.hrl").
   -include_lib("public_key/include/public_key.hrl").
   
  +-define(INTERVAL_METRIC, <<"heartbeat.interval">>).
   
   %% ------------------------------------------------------------------
   %% API Function Exports
  
positive.code: send_heartbeat(#state{command_sock = Sock,
                        org_name = OrgName,
                        sequence = Sequence,
                        session_key = SessionKey,
                        session_method = SessionMethod,
                        incarnation_id = IncarnationId,
  
negative.code: handle_info(start_heartbeat, #state{heartbeat_interval = Interval,
                                      node_name = NodeName} = State) ->
      lager:info("Starting heartbeat: [~s] (interval ~ws)", [NodeName, Interval]),
      folsom_metrics:new_histogram(?INTERVAL_METRIC),
      timer:apply_interval(Interval, ?MODULE, heartbeat, [self()]),
      {noreply, State#state{heartbeat_timestamp = pushy_time:timestamp()}};
  handle_info({zmq, Sock, Frame, [rcvmore]}, State) ->
      {noreply, receive_message(Sock, Frame, State)};
  handle_info(Info, #state{node_name = NodeName} = State) ->
  