Class TimedWeightedPriorityMessageQueue

    • Constructor Detail

      • TimedWeightedPriorityMessageQueue

        public TimedWeightedPriorityMessageQueue​(RouterContext ctx,
                                                 int[] priorityLimits,
                                                 int[] weighting,
                                                 TimedWeightedPriorityMessageQueue.FailedListener lsnr)
        Build up a new queue
        priorityLimits - ordered breakpoint for the different message priorities, with the lowest limit first.
        weighting - how much to prefer a given priority grouping. specifically, this means how many messages in this queue should be pulled off in a row before moving on to the next.