anchor.diff:          down ->
               gproc:send(subscribers_key(NodeRef), {down, NodeRef}),
               kick_from_rehab(State);
  -        up -> send_to_rehab(State)
  +        up -> send_to_rehab(Status, State)
       end.
   
   nlog(normal, Format, Args) ->
  
positive.code: %% Private Functions
  %%-----------------------------------------------------------------------------
  
  send_to_rehab(#state{node_ref = NodeRef} = State) ->
      {ok, TimerRef} = timer:send_interval(rehab_timer(), abort_nodes),
      lager:info("Added ~p to Rehab", [NodeRef]),
      State#state{rehab_timer = TimerRef}.
  
  kick_from_rehab(#state{rehab_timer = undefined} = State) ->
      State;
  kick_from_rehab(#state{rehab_timer = TimerRef, node_ref = NodeRef} = State) ->
      {ok, cancel} = timer:cancel(TimerRef),
      lager:info("Removed ~p from Rehab", [NodeRef]),
      State#state{rehab_timer = undefined}.
  
  rehab_timer() ->
      pushy_util:get_env(pushy, rehab_timer, fun is_integer/1).
  
negative.code:     State1 = State#state{logging=Level},
      {next_state, StateName, State1};
  handle_event(rehab, up, State) ->
      State1 = send_to_rehab(up, State),
      {next_state, up, State1};
  handle_event(rehab, down, State) ->
      {next_state, down, State};
  