org.axonframework.axonserver.connector.processor.grpc

Class GrpcEventProcessorInfoSource

java.lang.Object

org.axonframework.axonserver.connector.processor.grpc.GrpcEventProcessorInfoSource

All Implemented Interfaces:

EventProcessorInfoSource

public class GrpcEventProcessorInfoSource
extends Object
implements EventProcessorInfoSource

Implementation of EventProcessorInfoSource that send EventProcessor's status to Axon Server using gRPC messages.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
GrpcEventProcessorInfoSource(EventProcessingConfiguration eventProcessingConfiguration, AxonServerConnectionManager axonServerConnectionManager) Instantiate a EventProcessorInfoSource which can send EventProcessor status info to Axon Server.

Method Summary

Modifier and Type	Method and Description
void	notifyInformation()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcEventProcessorInfoSource

public GrpcEventProcessorInfoSource(EventProcessingConfiguration eventProcessingConfiguration,
                                    AxonServerConnectionManager axonServerConnectionManager)

Instantiate a EventProcessorInfoSource which can send EventProcessor status info to Axon Server. It uses the given EventProcessingConfiguration to retrieve all the EventProcessor instances and the provided AxonServerConnectionManager to send message to Axon Server.

Parameters:

eventProcessingConfiguration - the EventProcessingConfiguration from which the existing EventProcessor instances are retrieved

axonServerConnectionManager - the AxonServerConnectionManager used to send message to Axon Server

Method Detail

notifyInformation

public void notifyInformation()

Specified by:

notifyInformation in interface EventProcessorInfoSource