Top Fields Constructors Methods

io.github.resilience4j.core

public Class EventProcessor<T>

Class Inheritance

extends Object
implements EventPublisher<T>

java.lang.Object
io.github.resilience4j.core.EventProcessor

All Implemented Interfaces

io.github.resilience4j.core.EventPublisher

Known Direct Subclasses

io.github.resilience4j.core.registry.AbstractRegistry.RegistryEventProcessor

Imports

io.github.resilience4j.core.lang.Nullable, java.util.Set, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap, .CopyOnWriteArraySet, java.util.concurrent.locks.ReentrantLock

Field Summary

Modifier and Type	Field and Description
private boolean	consumerRegistered
pack-priv final ConcurrentMap<String, Set<EventConsumer<T>>>	eventConsumerMap
private final ReentrantLock	lock
pack-priv final Set<EventConsumer<T>>	onEventConsumers

Constructor Summary

Access	Constructor and Description
public	EventProcessor()

Method Summary

Modifier and Type	Method and Description
public boolean	hasConsumers()
public void	onEvent(EventConsumer<T> onEventConsumer) Implements io.github.resilience4j.core.EventPublisher.onEvent.
public <E extends T> boolean	processEvent(E event)
public void	registerConsumer(String className, EventConsumer<? extends T> eventConsumer)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

consumerRegistered	back to summary
private boolean consumerRegistered

eventConsumerMap	back to summary
pack-priv final ConcurrentMap<String, Set<EventConsumer<T>>> eventConsumerMap

lock	back to summary
private final ReentrantLock lock

onEventConsumers	back to summary
pack-priv final Set<EventConsumer<T>> onEventConsumers

Constructor Detail

EventProcessor	back to summary
public EventProcessor()

Method Detail

hasConsumers	back to summary
public boolean hasConsumers()

onEvent

back to summary

public void onEvent(EventConsumer<T> onEventConsumer)

Implements io.github.resilience4j.core.EventPublisher.onEvent.

Annotations

@Override

processEvent	back to summary
public <E extends T> boolean processEvent(E event)

registerConsumer	back to summary
public void registerConsumer(String className, EventConsumer<? extends T> eventConsumer) Annotations @SuppressWarnings:unchecked