Package io.github.resilience4j.bulkhead.internal

Class SemaphoreBulkhead.BulkheadEventProcessor

java.lang.Object

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

io.github.resilience4j.bulkhead.internal.SemaphoreBulkhead.BulkheadEventProcessor

All Implemented Interfaces:

Bulkhead.EventPublisher, io.github.resilience4j.core.EventConsumer<BulkheadEvent>, io.github.resilience4j.core.EventPublisher<BulkheadEvent>

Enclosing class:

SemaphoreBulkhead

private class SemaphoreBulkhead.BulkheadEventProcessor
extends io.github.resilience4j.core.EventProcessor<BulkheadEvent>
implements Bulkhead.EventPublisher, io.github.resilience4j.core.EventConsumer<BulkheadEvent>

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BulkheadEventProcessor()

Method Summary

Modifier and Type	Method	Description
void	consumeEvent(BulkheadEvent event)
Bulkhead.EventPublisher	onCallFinished(io.github.resilience4j.core.EventConsumer<BulkheadOnCallFinishedEvent> onCallFinishedEventConsumer)
Bulkhead.EventPublisher	onCallPermitted(io.github.resilience4j.core.EventConsumer<BulkheadOnCallPermittedEvent> onCallPermittedEventConsumer)
Bulkhead.EventPublisher	onCallRejected(io.github.resilience4j.core.EventConsumer<BulkheadOnCallRejectedEvent> onCallRejectedEventConsumer)

Methods inherited from class io.github.resilience4j.core.EventProcessor

hasConsumers, onEvent, processEvent, registerConsumer

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.resilience4j.core.EventPublisher

onEvent

Constructor Details

BulkheadEventProcessor

private BulkheadEventProcessor()

Method Details

onCallPermitted

public Bulkhead.EventPublisher onCallPermitted(io.github.resilience4j.core.EventConsumer<BulkheadOnCallPermittedEvent> onCallPermittedEventConsumer)

Specified by:

onCallPermitted in interface Bulkhead.EventPublisher

onCallRejected

public Bulkhead.EventPublisher onCallRejected(io.github.resilience4j.core.EventConsumer<BulkheadOnCallRejectedEvent> onCallRejectedEventConsumer)

Specified by:

onCallRejected in interface Bulkhead.EventPublisher

onCallFinished

public Bulkhead.EventPublisher onCallFinished(io.github.resilience4j.core.EventConsumer<BulkheadOnCallFinishedEvent> onCallFinishedEventConsumer)

Specified by:

onCallFinished in interface Bulkhead.EventPublisher

consumeEvent

public void consumeEvent(BulkheadEvent event)

Specified by:

consumeEvent in interface io.github.resilience4j.core.EventConsumer<BulkheadEvent>