Package org.elasticsearch.transport

Class TcpTransport.ScheduledPing

java.lang.Object

org.elasticsearch.common.util.concurrent.AbstractRunnable

org.elasticsearch.common.util.concurrent.AbstractLifecycleRunnable

org.elasticsearch.transport.TcpTransport.ScheduledPing

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

TcpTransport

public class TcpTransport.ScheduledPing
extends AbstractLifecycleRunnable

Constructor Summary

Constructors

Constructor	Description
ScheduledPing()

Method Summary

Modifier and Type	Method	Description
protected void	doRunInLifecycle()	Perform runnable logic, but only if the AbstractLifecycleRunnable.lifecycle is not stopped or closed.
long	getFailedPings()
long	getSuccessfulPings()
protected void	onAfterInLifecycle()	This method is invoked in the finally block of the run method, but it is only executed if the AbstractLifecycleRunnable.lifecycle is not stopped or closed.
void	onFailure(java.lang.Exception e)	This method is invoked for all exception thrown by AbstractRunnable.doRun()

Methods inherited from class org.elasticsearch.common.util.concurrent.AbstractLifecycleRunnable

doRun, onAfter

Methods inherited from class org.elasticsearch.common.util.concurrent.AbstractRunnable

isForceExecution, onRejection, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScheduledPing

public ScheduledPing()

Method Detail

doRunInLifecycle

protected void doRunInLifecycle()
                         throws java.lang.Exception

Description copied from class: AbstractLifecycleRunnable

Perform runnable logic, but only if the AbstractLifecycleRunnable.lifecycle is not stopped or closed.

Specified by:

doRunInLifecycle in class AbstractLifecycleRunnable

Throws:

java.lang.InterruptedException - if the run method throws an InterruptedException

java.lang.Exception

getSuccessfulPings

public long getSuccessfulPings()

getFailedPings

public long getFailedPings()

onAfterInLifecycle

protected void onAfterInLifecycle()

Description copied from class: AbstractLifecycleRunnable

This method is invoked in the finally block of the run method, but it is only executed if the AbstractLifecycleRunnable.lifecycle is not stopped or closed.

This method is most useful for rescheduling the next iteration of the current runnable.

Overrides:

onAfterInLifecycle in class AbstractLifecycleRunnable

onFailure

public void onFailure(java.lang.Exception e)

Description copied from class: AbstractRunnable

This method is invoked for all exception thrown by AbstractRunnable.doRun()

Specified by:

onFailure in class AbstractRunnable