Package com.oracle.coherence.concurrent

Class Queues

java.lang.Object

com.oracle.coherence.concurrent.Queues

public class Queues
extends Object

A factory to obtain named blocking queues.

Field Summary

Fields

Modifier and Type	Field	Description
static final com.tangosol.internal.net.queue.NamedCacheDequeBuilder	BUILDER	The NamedCacheDequeBuilder used to ensure a blocking queue is created from the concurrent session with the correct name suffix.
static final String	QUEUE_CACHE_PREFIX	The prefix use for queue cache names.
static final String	SESSION_NAME	The session name.

Constructor Summary

Constructors

Constructor	Description
Queues()

Method Summary

Modifier and Type	Method	Description
static <E> NamedBlockingQueue<E>	blocking(String sName)	Return a NamedBlockingQueue.
static <E> NamedBlockingDeque<E>	blockingDeque(String sName)	Return a NamedBlockingDeque.
protected static <E> NamedBlockingDeque<E>	ensureQueue(String sName)
protected static Session	session()	Return Coherence Session for the Semaphore module.

Methods inherited from class java.lang.Object

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

Field Details

QUEUE_CACHE_PREFIX

public static final String QUEUE_CACHE_PREFIX

The prefix use for queue cache names.

See Also:

• Constant Field Values

SESSION_NAME

public static final String SESSION_NAME

The session name.

BUILDER

public static final com.tangosol.internal.net.queue.NamedCacheDequeBuilder BUILDER

The NamedCacheDequeBuilder used to ensure a blocking queue is created from the concurrent session with the correct name suffix.

Constructor Details

Queues

public Queues()

Method Details

blockingDeque

public static <E> NamedBlockingDeque<E> blockingDeque(String sName)

Return a NamedBlockingDeque.

Type Parameters:

E - the type of element in the queue

Parameters:

sName - the name of the queue to return

Returns:

a NamedBlockingDeque with the specified name

blocking

public static <E> NamedBlockingQueue<E> blocking(String sName)

Return a NamedBlockingQueue.

Type Parameters:

E - the type of element in the queue

Parameters:

sName - the name of the queue to return

Returns:

a NamedBlockingQueue with the specified name

session

protected static Session session()

Return Coherence Session for the Semaphore module.

Returns:

Coherence Session for the Semaphore module

ensureQueue

protected static <E> NamedBlockingDeque<E> ensureQueue(String sName)