org.apache.directory.server.ldap.replication.consumer

Class PingerThread

java.lang.Object

java.lang.Thread

org.apache.directory.server.ldap.replication.consumer.PingerThread

All Implemented Interfaces:

java.lang.Runnable

public class PingerThread
extends java.lang.Thread

A thread used to ping the provider o check if they are alive or not.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	CONSUMER_LOG Logger for the replication consumer
private java.util.Queue<ReplicationConsumer>	consumers The list of consumers we want to check
private long	sleepTime the time interval before this thread pings each replication provider.
private boolean	stop A flag to stop the pinger

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
PingerThread(int sleepSec) Create a new instance of this thread.

Method Summary

Modifier and Type	Method and Description
void	addConsumer(ReplicationConsumer consumer) Add a new consumer to ping
void	removeConsumer(ReplicationConsumer consumer) Remove a consumer to ping
void	run() Starts the thread
void	stopPinging() Stops the ping for all the consumers

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

CONSUMER_LOG

private static final org.slf4j.Logger CONSUMER_LOG

Logger for the replication consumer

consumers

private java.util.Queue<ReplicationConsumer> consumers

The list of consumers we want to check

stop

private boolean stop

A flag to stop the pinger

sleepTime

private long sleepTime

the time interval before this thread pings each replication provider. Default value is 5 seconds

Constructor Detail

PingerThread

public PingerThread(int sleepSec)

Create a new instance of this thread.

Parameters:

sleepSec - the number of seconds pinger thread should sleep before pinging the providers

Method Detail

run

public void run()

Starts the thread

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

addConsumer

public void addConsumer(ReplicationConsumer consumer)

Add a new consumer to ping

Parameters:

consumer - The consumer we want to ping

removeConsumer

public void removeConsumer(ReplicationConsumer consumer)

Remove a consumer to ping

Parameters:

consumer - The consumer we want to remove

stopPinging

public void stopPinging()

Stops the ping for all the consumers