Interface EventConsumerRegistry
-
public interface EventConsumerRegistryRegistry that manages all theEventConsumerobjects of the event gateway microservice. This component offers functionality to add, remove and retrieve all the event consumers.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidderegister(EventConsumer eventConsumer)Remove an existingEventConsumerfrom the registry, so that it doesn't receive any new events.Stream<EventConsumer>getAll()Retrieve all the registeredEventConsumerobjects in the registry.voidregister(EventConsumer eventConsumer)Add a newEventConsumerto the registry if it wasn't already registered.
-
-
-
Method Detail
-
register
void register(EventConsumer eventConsumer)
Add a newEventConsumerto the registry if it wasn't already registered. From this moment, it starts receiving new events.- Parameters:
eventConsumer- theEventConsumerto register
-
deregister
void deregister(EventConsumer eventConsumer)
Remove an existingEventConsumerfrom the registry, so that it doesn't receive any new events.- Parameters:
eventConsumer- theEventConsumerto remove from the registry
-
getAll
Stream<EventConsumer> getAll()
Retrieve all the registeredEventConsumerobjects in the registry.- Returns:
- a
Streamwith all theEventConsumerobjects of the registry
-
-