org.fusesource.hawtdispatch.transport
Class HeartBeatMonitor

java.lang.Object
  extended by org.fusesource.hawtdispatch.transport.HeartBeatMonitor

public class HeartBeatMonitor
extends 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.

Author:
Hiram Chirino

Constructor Summary
HeartBeatMonitor()
           
 
Method Summary
 long getInitialReadCheckDelay()
           
 long getInitialWriteCheckDelay()
           
 Task getOnDead()
           
 Task getOnKeepAlive()
           
 long getReadInterval()
           
 Transport getTransport()
           
 long getWriteInterval()
           
 void resumeRead()
           
 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
 

Constructor Detail

HeartBeatMonitor

public HeartBeatMonitor()
Method Detail

suspendRead

public void suspendRead()

resumeRead

public void resumeRead()

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)


Copyright © 2010-2014 FuseSource, Corp.. All Rights Reserved.