org.axonframework.axonserver.connector.heartbeat

Class HeartbeatMonitor

java.lang.Object

org.axonframework.axonserver.connector.heartbeat.HeartbeatMonitor

public class HeartbeatMonitor
extends Object

Verifies if the connection is still alive, and react if it is not.

Since:

4.2.1

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
HeartbeatMonitor(AxonServerConnectionManager connectionManager, String context) Constructs an instance of HeartbeatMonitor that forces a disconnection when the AxonServer connection is no longer alive.
HeartbeatMonitor(Runnable onInvalidConnection, ConnectionSanityChecker connectionSanityCheck, Scheduler scheduler, long initialDelay, long delay) Primary constructor of HeartbeatMonitor.

Method Summary

Modifier and Type	Method and Description
void	shutdown() Stops the scheduled task and shutdown the monitor, that cannot be restarted again.
void	start() Schedule a task that verifies that the connection is still alive and, if it is not, invoke a callback in order to react to the disconnection.

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartbeatMonitor

public HeartbeatMonitor(AxonServerConnectionManager connectionManager,
                        String context)

Constructs an instance of HeartbeatMonitor that forces a disconnection when the AxonServer connection is no longer alive.

Parameters:

connectionManager - connectionManager to AxonServer

context - the (Bounded) Context for which the heartbeat activity is monitored

HeartbeatMonitor

public HeartbeatMonitor(Runnable onInvalidConnection,
                        ConnectionSanityChecker connectionSanityCheck,
                        Scheduler scheduler,
                        long initialDelay,
                        long delay)

Primary constructor of HeartbeatMonitor.

Parameters:

onInvalidConnection - callback to be call when the connection is no longer alive

connectionSanityCheck - sanity check which allows to verify if the connection is alive

scheduler - the Scheduler to use for scheduling the task

initialDelay - the initial delay, in milliseconds

delay - the scheduling period, in milliseconds

Method Detail

start

@StartHandler(phase=1073741833)
public void start()

Schedule a task that verifies that the connection is still alive and, if it is not, invoke a callback in order to react to the disconnection. Started in phase Phase.INSTRUCTION_COMPONENTS, as this means all inbound and outbound connections have been started.

shutdown

@ShutdownHandler(phase=1073741833)
public void shutdown()

Stops the scheduled task and shutdown the monitor, that cannot be restarted again. Shuts down in phase Phase.INSTRUCTION_COMPONENTS.