public class InvocationMonitor extends Object implements PacketHandler, MetricsProvider
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.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() |
public ConcurrentMap<Address,AtomicLong> getHeartbeatPerMember()
public long getHeartbeatBroadcastPeriodMillis()
public void provideMetrics(MetricsRegistry registry)
provideMetrics
in interface MetricsProvider
public void handle(Packet packet)
PacketHandler
handle
in interface PacketHandler
packet
- the response packet to handlepublic void start()
public void shutdown()
public void awaitTermination(long timeoutMillis) throws InterruptedException
InterruptedException
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.