I- Type of the incoming payload
O- Type of the outgoing payload
public interface HeartbeatListener<I,O>
HeartbeatManager. The heartbeat listener is used for the following things:
|Modifier and Type||Method and Description|
Callback which is called if a heartbeat for the machine identified by the given resource ID times out.
Callback which is called whenever a heartbeat with an associated payload is received.
Retrieves the payload value for the next heartbeat message.
void notifyHeartbeatTimeout(ResourceID resourceID)
resourceID- Resource ID of the machine whose heartbeat has timed out
void reportPayload(ResourceID resourceID, I payload)
resourceID- Resource ID identifying the sender of the payload
payload- Payload of the received heartbeat
CompletableFuture<O> retrievePayload(ResourceID resourceID)
resourceID- Resource ID identifying the receiver of the payload
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.