Interface GroupedPublisher.QueueSizeProvider

  • Enclosing class:
    GroupedPublisher<Key,​T>

    public static interface GroupedPublisher.QueueSizeProvider
    Provide the maximum queue size to use for a particular GroupedPublisher key.
    • Method Detail

      • calculateMaxQueueSize

        int calculateMaxQueueSize​(int groupMaxQueueSize)
        Calculate the maximum queue size for a particular GroupedPublisher key.
        Parameters:
        groupMaxQueueSize - The maximum queue size for GroupedPublisher objects.
        Returns:
        The maximum queue size for a particular GroupedPublisher key.