com.hazelcast.spi.impl.operationservice.impl

Class InvocationMonitor

java.lang.Object

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

All Implemented Interfaces:

MetricsProvider, Consumer<Packet>

public class InvocationMonitor
extends Object
implements Consumer<Packet>, 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	accept(Packet packet) Performs this operation on the given argument.
void	awaitTermination(long timeoutMillis)
long	getHeartbeatBroadcastPeriodMillis()
ConcurrentMap<Address,AtomicLong>	getHeartbeatPerMember()
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

accept

public void accept(Packet packet)

Description copied from interface: Consumer

Performs this operation on the given argument.

Specified by:

accept in interface Consumer<Packet>

Parameters:

packet - the input argument

start

public void start()

shutdown

public void shutdown()

awaitTermination

public void awaitTermination(long timeoutMillis)
                      throws InterruptedException

Throws:

InterruptedException