org.fusesource.hawtdispatch.transport

Class HeartBeatMonitor

java.lang.Object

org.fusesource.hawtdispatch.transport.HeartBeatMonitor

public class HeartBeatMonitor
extends java.lang.Object

A HeartBeatMonitor can be used to watch the read and write activity of a transport and raise events when the write side or read side has been idle too long.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	initialReadCheckDelay
(package private) long	initialWriteCheckDelay
(package private) java.lang.Object	lock
(package private) Task	onDead
(package private) Task	onKeepAlive
(package private) long	readInterval
(package private) short	readSuspendCount
(package private) boolean	readSuspendedInterval
(package private) short	session
(package private) Transport	transport
(package private) long	writeInterval

Constructor Summary

Constructors

Constructor and Description
HeartBeatMonitor()

Method Summary

Modifier and Type	Method and Description
long	getInitialReadCheckDelay()
long	getInitialWriteCheckDelay()
Task	getOnDead()
Task	getOnKeepAlive()
long	getReadInterval()
Transport	getTransport()
long	getWriteInterval()
void	resumeRead()
private void	schedule(short session, long interval, Task func)
private void	scheduleCheckReads(short session)
private void	scheduleCheckWrites(short session)
void	setInitialReadCheckDelay(long initialReadCheckDelay)
void	setInitialWriteCheckDelay(long initialWriteCheckDelay)
void	setOnDead(Task onDead)
void	setOnKeepAlive(Task onKeepAlive)
void	setReadInterval(long readInterval)
void	setTransport(Transport transport)
void	setWriteInterval(long writeInterval)
void	start()
void	stop()
void	suspendRead()

Methods inherited from class java.lang.Object

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

Field Detail

transport

Transport transport

initialWriteCheckDelay

long initialWriteCheckDelay

initialReadCheckDelay

long initialReadCheckDelay

writeInterval

long writeInterval

readInterval

long readInterval

onKeepAlive

Task onKeepAlive

onDead

Task onDead

session

volatile short session

readSuspendedInterval

boolean readSuspendedInterval

readSuspendCount

short readSuspendCount

lock

java.lang.Object lock

Constructor Detail

HeartBeatMonitor

public HeartBeatMonitor()

Method Detail

suspendRead

public void suspendRead()

resumeRead

public void resumeRead()

schedule

private void schedule(short session,
                      long interval,
                      Task func)

scheduleCheckWrites

private void scheduleCheckWrites(short session)

scheduleCheckReads

private void scheduleCheckReads(short session)

start

public void start()

stop

public void stop()

getInitialReadCheckDelay

public long getInitialReadCheckDelay()

setInitialReadCheckDelay

public void setInitialReadCheckDelay(long initialReadCheckDelay)

getInitialWriteCheckDelay

public long getInitialWriteCheckDelay()

setInitialWriteCheckDelay

public void setInitialWriteCheckDelay(long initialWriteCheckDelay)

getOnDead

public Task getOnDead()

setOnDead

public void setOnDead(Task onDead)

getOnKeepAlive

public Task getOnKeepAlive()

setOnKeepAlive

public void setOnKeepAlive(Task onKeepAlive)

getWriteInterval

public long getWriteInterval()

setWriteInterval

public void setWriteInterval(long writeInterval)

getTransport

public Transport getTransport()

setTransport

public void setTransport(Transport transport)

getReadInterval

public long getReadInterval()

setReadInterval

public void setReadInterval(long readInterval)