Package org.jppf.comm.recovery

Class HeartbeatConnection

java.lang.Object

org.jppf.utils.concurrent.ThreadSynchronization

org.jppf.comm.recovery.AbstractHeartbeatConnection

org.jppf.comm.recovery.HeartbeatConnection

All Implemented Interfaces:

Runnable

public class HeartbeatConnection
extends AbstractHeartbeatConnection

Client-side connection for the recovery mechanism.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.comm.recovery.AbstractHeartbeatConnection

initialized, maxRetries, ok, runThread, socketReadTimeout, socketWrapper, uuid

Fields inherited from class org.jppf.utils.concurrent.ThreadSynchronization

stopped

Constructor Summary

Constructors

Constructor	Description
HeartbeatConnection(int channelIdentifier, String uuid, String host, int port, boolean sslEnabled, TypedProperties config)	Initialize this client connection with the specified uuid.

Method Summary

Modifier and Type	Method	Description
void	addClientConnectionListener(HeartbeatConnectionListener listener)	Add a listener to the list of listeners.
void	close()	Close this client and release any resources it is using.
void	removeClientConnectionListener(HeartbeatConnectionListener listener)	Remove a listener from the list of listeners.
void	run()

Methods inherited from class org.jppf.comm.recovery.AbstractHeartbeatConnection

getSocketWrapper, getUuid, isInitialized, isOk, receiveMessage, receiveMessage, sendMessage, setInitialized, setOk, toString

Methods inherited from class org.jppf.utils.concurrent.ThreadSynchronization

goToSleep, goToSleep, goToSleep, isStopped, setStopped, wakeUp

Methods inherited from class java.lang.Object

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

Constructor Details

HeartbeatConnection

public HeartbeatConnection(int channelIdentifier,
 String uuid,
 String host,
 int port,
 boolean sslEnabled,
 TypedProperties config)

Initialize this client connection with the specified uuid.

Parameters:

uuid - the JPPF node or client uuid.

host - the host ot which to connect.

port - the port number to connect to on the host.

sslEnabled - whether secure connectivity is enabled.

channelIdentifier - identifies this channel with the server.

config - contains the location or source of the SSL configuration.

Method Details

run

public void run()

close

public void close()

Description copied from class: AbstractHeartbeatConnection

Close this client and release any resources it is using.

Specified by:

close in class AbstractHeartbeatConnection

addClientConnectionListener

public void addClientConnectionListener(HeartbeatConnectionListener listener)

Add a listener to the list of listeners.

Parameters:

listener - the listener to add.

removeClientConnectionListener

public void removeClientConnectionListener(HeartbeatConnectionListener listener)

Remove a listener from the list of listeners.

Parameters:

listener - the listener to remove.