public class GrpcEventProcessorInfoSource extends Object implements EventProcessorInfoSource
EventProcessorInfoSource
that send EventProcessor
's status to Axon Server using
gRPC messages.Constructor and Description |
---|
GrpcEventProcessorInfoSource(EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConnectionManager axonServerConnectionManager,
String context)
Instantiate a
EventProcessorInfoSource which can send EventProcessor status info to Axon Server. |
Modifier and Type | Method and Description |
---|---|
void |
notifyInformation() |
public GrpcEventProcessorInfoSource(EventProcessingConfiguration eventProcessingConfiguration, AxonServerConnectionManager axonServerConnectionManager, String context)
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.eventProcessingConfiguration
- the EventProcessingConfiguration
from which the existing
EventProcessor
instances are retrievedaxonServerConnectionManager
- the AxonServerConnectionManager
used to send message to Axon Servercontext
- the context of this application instance in which EventProcessor
status' should be sendpublic void notifyInformation()
notifyInformation
in interface EventProcessorInfoSource
Copyright © 2010–2020. All rights reserved.