org.axonframework.axonserver.connector.heartbeat.source

Class GrpcHeartbeatSource

java.lang.Object

org.axonframework.axonserver.connector.heartbeat.source.GrpcHeartbeatSource

All Implemented Interfaces:

HeartbeatSource

public class GrpcHeartbeatSource
extends Object
implements HeartbeatSource

gRPC implementation of HeartbeatSource, which sends to AxonServer a Heartbeat message.

Since:

4.2.1

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
GrpcHeartbeatSource(AxonServerConnectionManager connectionManager, String context) Creates a GrpcHeartbeatSource which uses an AxonServerConnectionManager to send heartbeats messages to AxonServer.

Method Summary

Modifier and Type	Method and Description
void	pulse() Send an heartbeat to AxonServer

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcHeartbeatSource

public GrpcHeartbeatSource(AxonServerConnectionManager connectionManager,
                           String context)

Creates a GrpcHeartbeatSource which uses an AxonServerConnectionManager to send heartbeats messages to AxonServer.

Parameters:

connectionManager - the AxonServerConnectionManager

context - defines the (Bounded) Context for which heartbeats are sent

Method Detail

pulse

public void pulse()

Send an heartbeat to AxonServer

Sends a PlatformInboundInstruction to AxonServer that contains a Heartbeat message.

Specified by:

pulse in interface HeartbeatSource