Class EventProcessor<T>

java.lang.Object

io.github.resilience4j.core.EventProcessor<T>

All Implemented Interfaces:

EventPublisher<T>

Direct Known Subclasses:

AbstractRegistry.RegistryEventProcessor

public class EventProcessor<T>
extends Object
implements EventPublisher<T>

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	consumerRegistered
(package private) final ConcurrentMap<String, List<EventConsumer<T>>>	eventConsumerMap
(package private) final List<EventConsumer<T>>	onEventConsumers

Constructor Summary

Constructors

Constructor	Description
EventProcessor()

Method Summary

Modifier and Type	Method	Description
boolean	hasConsumers()
void	onEvent(EventConsumer<T> onEventConsumer)
<E extends T> boolean	processEvent(E event)
void	registerConsumer(String className, EventConsumer<? extends T> eventConsumer)

Methods inherited from class Object

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

Field Details

onEventConsumers

final List<EventConsumer<T>> onEventConsumers

eventConsumerMap

final ConcurrentMap<String, List<EventConsumer<T>>> eventConsumerMap

consumerRegistered

private boolean consumerRegistered

Constructor Details

EventProcessor

public EventProcessor()

Method Details

hasConsumers

public boolean hasConsumers()

registerConsumer

public void registerConsumer(String className,
 EventConsumer<? extends T> eventConsumer)

processEvent

public <E extends T> boolean processEvent(E event)

onEvent

public void onEvent(@Nullable
 EventConsumer<T> onEventConsumer)

Specified by:

onEvent in interface EventPublisher<T>