anchor.diff:      lager:debug("Received heartbeat for node ~p with job id ~p", [NodeRef, JobId]),
       case JobId /= null andalso pushy_job_state_sup:get_process(JobId) == not_found of
           true ->
  -            gen_fsm:send_event(self(), rehab);
  +            gen_fsm:send_event(self(), do_rehab);
           _ ->
               ok
       end,
  
positive.code:     lager:info("~p in rehab. Ignoring message: ~p~n", [NodeRef, Message]),
      {next_state, rehab, State}.
  
  idle(rehab, State) ->
      force_abort(State),
      State1 = State#state{availability=unavailable},
      {next_state, state_transition(idle, rehab, State1), State1};
  
negative.code:     end.
  
  rehab(NodeRef) ->
      case cast(NodeRef, do_rehab) of
          ok ->
              ok;
          Error ->
  