question: creates the task that sends a ping message to the members of the cluster . task will be invoked periodically with fixed delay . concode_field_sep long invalidateAfterNodeCrashDelay concode_elem_sep ConcurrentMap<String,ScheduledFuture<?>> invalidateAfterNodeCrashSchedules concode_elem_sep Logger LOGGER concode_elem_sep ScheduledExecutorService schedulerService concode_elem_sep int PING_SCHEDULER_CORE_POOL_SIZE concode_elem_sep ScheduledFuture<?> pingSenderSchedule concode_elem_sep long pingPeriod concode_elem_sep MapInvalidator invalidator concode_elem_sep long messageOrderCheckDelay concode_elem_sep NodeRegistry nodeRegistry concode_elem_sep ConcurrentMap<String,ScheduledFuture<?>> messageOrderCheckSchedules concode_elem_sep PingSender pingSender concode_elem_sep long DEFAULT_PING_PERIOD concode_elem_sep long DEFAULT_INVALIDATE_TIMEOUT concode_field_sep ScheduledExecutorService createSchedulerService concode_elem_sep void setInvalidateAfterNodeCrashDelay concode_elem_sep void setMessageOrderCheckDelay concode_elem_sep void scheduleMessageOrderCheck concode_elem_sep void scheduleInvalidateOnNodeCrash concode_elem_sep Runnable createInvalidateAfterNodeCrashTask concode_elem_sep void schedulePingSender concode_elem_sep Runnable createMessageOrderCheckTask concode_elem_sep long getInvalidateAfterNodeCrashDelay concode_elem_sep long getPingPeriod concode_elem_sep void setPingPeriod concode_elem_sep long getMessageOrderCheckDelay concode_elem_sep void shutdown
target: Runnable function ( ) { return pingSender :: ping ; }