anchor.diff:                     node_id = NodeId,
                      incarnation_id = IncarnationId
                     },
  +    lager:info("Starting heartbeat for ~s (interval ~ws)", [NodeId, Interval]),
       {ok, _Timer} = timer:apply_interval(Interval, ?MODULE, heartbeat, [self()]),
       {ok, State}.
   
  
positive.code:     lager:debug("Heartbeat sent: header=~s,body=~s",[HeaderFrame, BodyFrame]),
      State#state{sequence=Sequence + 1}.
  
  send_response(Type, JobId, #state{command_sock = Sock,
                                    client_name = ClientName,
                                    private_key = PrivateKey,
                                    incarnation_id = IncarnationId,
                                    node_id = NodeId}) ->
      Msg = {[{node, NodeId},
              {client, ClientName},
              {org, "pushy"},
  
negative.code: -behaviour(gen_server).
  -define(SERVER, ?MODULE).
  
  -include_lib("eunit/include/eunit.hrl").
  -include_lib("erlzmq/include/erlzmq.hrl").
  -include("pushysim.hrl").
  -include_lib("pushy_common/include/pushy_client.hrl").
  -include_lib("pushy_common/include/pushy_metrics.hrl").
  
  
  %% ------------------------------------------------------------------
  %% API Function Exports
  %% ------------------------------------------------------------------
  
  -export([start_link/2,
           heartbeat/1
          ]).
  
  %% ------------------------------------------------------------------
  