lbmq

Class DefaultSubQueueSelection<K,E>

java.lang.Object

lbmq.DefaultSubQueueSelection<K,E>

All Implemented Interfaces:

LinkedBlockingMultiQueue.SubQueueSelection<K,E>

public class DefaultSubQueueSelection<K,E>
extends java.lang.Object
implements LinkedBlockingMultiQueue.SubQueueSelection<K,E>

Chooses the next queue to be used from the highest priority priority group. If no queue is found it searches the lower priority groups and so on until it finds a queue.

Constructor Summary

Constructors

Constructor and Description
DefaultSubQueueSelection()

Method Summary

Modifier and Type	Method and Description
LinkedBlockingMultiQueue.SubQueue	getNext() Returns the next subQueue to be used.
E	peek() Returns the next element from the queue but keeps it in the queue.
void	setPriorityGroups(java.util.ArrayList<lbmq.LinkedBlockingMultiQueue.PriorityGroup> priorityGroups) Sets priority groups.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSubQueueSelection

public DefaultSubQueueSelection()

Method Detail

getNext

public LinkedBlockingMultiQueue.SubQueue getNext()

Description copied from interface: LinkedBlockingMultiQueue.SubQueueSelection

Returns the next subQueue to be used.

Specified by:

getNext in interface LinkedBlockingMultiQueue.SubQueueSelection<K,E>

Returns:

a subQueue

peek

public E peek()

Description copied from interface: LinkedBlockingMultiQueue.SubQueueSelection

Returns the next element from the queue but keeps it in the queue.

Specified by:

peek in interface LinkedBlockingMultiQueue.SubQueueSelection<K,E>

Returns:

the next element from the queue

setPriorityGroups

public void setPriorityGroups(java.util.ArrayList<lbmq.LinkedBlockingMultiQueue.PriorityGroup> priorityGroups)

Description copied from interface: LinkedBlockingMultiQueue.SubQueueSelection

Sets priority groups.

Specified by:

setPriorityGroups in interface LinkedBlockingMultiQueue.SubQueueSelection<K,E>

Parameters:

priorityGroups - priority groups