com.hazelcast.spi.impl.operationservice.impl

Class InvocationMonitor

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.InvocationMonitor

All Implemented Interfaces:

MetricsProvider, PacketHandler

public class InvocationMonitor
extends Object
implements PacketHandler, MetricsProvider

The InvocationMonitor monitors all pending invocations and determines if there are any problems like timeouts. It uses the InvocationRegistry to access the pending invocations. The InvocationMonitor sends Operation heartbeats to the other member informing them about if the operation is still alive. Also if no operations are running, it will still send a period packet to each member. This is a different system than the regular heartbeats, but it has similar characteristics. The reason the packet is always send is for debugging purposes.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination(long timeoutMillis)
long	getHeartbeatBroadcastPeriodMillis()
ConcurrentMap<Address,AtomicLong>	getHeartbeatPerMember()
void	handle(Packet packet) Signals the PacketHandler that there is a packet to be handled.
void	provideMetrics(MetricsRegistry registry)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Method Detail

getHeartbeatPerMember

public ConcurrentMap<Address,AtomicLong> getHeartbeatPerMember()

getHeartbeatBroadcastPeriodMillis

public long getHeartbeatBroadcastPeriodMillis()

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

handle

public void handle(Packet packet)

Description copied from interface: PacketHandler

Signals the PacketHandler that there is a packet to be handled.

Specified by:

handle in interface PacketHandler

Parameters:

packet - the response packet to handle

start

public void start()

shutdown

public void shutdown()

awaitTermination

public void awaitTermination(long timeoutMillis)
                      throws InterruptedException

Throws:

InterruptedException