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