Package com.swiftmq.impl.streams.comp.memory.limit

Interface Limit

All Known Implementing Classes:
CountLimit, TimeLimit, TimeUnitChangeLimit
public interface Limit
Base interface for Memory Limits.
Author:
IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    checkLimit()
    Checks the Memory limits and deletes Messages that doesn't fit in the limit
    LimitBuilder
    limit()
    Creates a new LimitBuilder and that chains new Limits to the corresponding Memory
    Limit
    onRetire(RetirementCallback callback)
    Sets a callback which is called for each Message that is retired (removed by a Limit).

  • Method Details

    • checkLimit

      void checkLimit()
      Checks the Memory limits and deletes Messages that doesn't fit in the limit

    • onRetire

      Limit onRetire(RetirementCallback callback)
      Sets a callback which is called for each Message that is retired (removed by a Limit).
      Parameters:
      callback - Callback
      Returns:
      Limit

    • limit

      LimitBuilder limit()
      Creates a new LimitBuilder and that chains new Limits to the corresponding Memory
      Returns:
      LimitBuilder