Module io.helidon.faulttolerance
Package io.helidon.faulttolerance

Interface Bulkhead.QueueListener

Enclosing interface:
Bulkhead
public static interface Bulkhead.QueueListener
A Bulkhead listener for queueing operations.

  • Method Summary

    Modifier and Type
    Method
    Description
    default <T> void
    dequeued(Supplier<? extends T> supplier)
    Called after semaphore is acquired and before supplier is called.
    default <T> void
    enqueueing(Supplier<? extends T> supplier)
    Called right before blocking on the internal semaphore's queue.

  • Method Details

    • enqueueing

      default <T> void enqueueing(Supplier<? extends T> supplier)
      Called right before blocking on the internal semaphore's queue.
      Type Parameters:
      T - type of value returned by supplier
      Parameters:
      supplier - the supplier to be enqueued

    • dequeued

      default <T> void dequeued(Supplier<? extends T> supplier)
      Called after semaphore is acquired and before supplier is called.
      Type Parameters:
      T - type of value returned by supplier
      Parameters:
      supplier - the supplier to execute