Interface LimitHandler

  • Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

    @FunctionalInterface
    public interface LimitHandler
    The default interface to be used for executing logic when buffer limit is reached.
    Since:
    0.8.0
    See Also:
    BlockingRecordQueue
    • Method Detail

      • onLimitReached

        <K,​V> void onLimitReached​(BlockingRecordQueue<K,​V> queue)
        Invokes when the limit of a BlockingRecordQueue is reached.
        Parameters:
        queue - the queue that reached its limit.