org.jredis.ri.alphazero.connection

Class HeartbeatJinn

java.lang.Object

java.lang.Thread

org.jredis.ri.alphazero.connection.HeartbeatJinn

All Implemented Interfaces:

Runnable, Connection.Listener

public class HeartbeatJinn
extends Thread
implements Connection.Listener

A demon thread tasked with PINGing the associated connection per its ConnectionSpec.getHeartbeat() heartbeat interval.

HeartbeatJinns are Connection.Listeners, and rely on Connection event propagation to synchronize their activity with the associated connection.

The connection must only call Thread.start() when it has established its connectivity.

Since:

alpha.0

Version:

alpha.0, Nov 22, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
HeartbeatJinn(Connection conn, int periodInSecs, String name) Instantiate and initialize the HeartbeatJinn.

Method Summary

Modifier and Type	Method and Description
void	onEvent(Connection.Event event)
void	run() Your basic infinite loop with branchings on connection state and modality
void	shutdown()

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

Constructor Detail

HeartbeatJinn

public HeartbeatJinn(Connection conn,
                     int periodInSecs,
                     String name)

Instantiate and initialize the HeartbeatJinn. On return, this instance is:

sets flag to work added to the listeners for the connection assumes connection is not yet established

Parameters:

conn - associated with this instnace

periodInSecs - a reasonable value is 1. Internally converted to millisecs.

name - associated with this (heartbeat) thread.

Method Detail

shutdown

public void shutdown()

run

public void run()

Your basic infinite loop with branchings on connection state and modality

TODO: run loop should be a proper state machine. TODO: delouse this baby ..

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

Thread.run()

onEvent

public void onEvent(Connection.Event event)

Specified by:

onEvent in interface Connection.Listener

See Also:

Connection.Listener.onEvent(org.jredis.connector.Connection.Event)