Package | Description |
---|---|
org.apache.synapse.commons.executors | |
org.apache.synapse.commons.executors.queues |
Modifier and Type | Method and Description |
---|---|
InternalQueue<E> |
PRRNextQueueAlgorithm.getNextQueue() |
InternalQueue<E> |
NextQueueAlgorithm.getNextQueue()
Should return a queue based on some selection criteria and current
state of the queues.
|
Modifier and Type | Method and Description |
---|---|
List<InternalQueue<E>> |
MultiPriorityBlockingQueue.getQueues() |
Modifier and Type | Method and Description |
---|---|
void |
PRRNextQueueAlgorithm.init(List<InternalQueue<E>> queues) |
void |
NextQueueAlgorithm.init(List<InternalQueue<E>> queues)
Initialized with the queues sorted according to the priority.
|
Constructor and Description |
---|
MultiPriorityBlockingQueue(List<InternalQueue<E>> queues,
boolean isFixedQueues,
NextQueueAlgorithm<E> algorithm)
Create a queue with the given queues.
|
Modifier and Type | Class and Description |
---|---|
class |
FixedSizeQueue<E>
A bounded queue implementation for internal queues.
|
class |
UnboundedQueue<E>
An unbounded queue backed by and ArrayList.
|
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.