Package adams.flow.core

Class QueueHelper

java.lang.Object

adams.flow.core.QueueHelper

public class QueueHelper
extends Object

Helper class for queue handling.

Version:

$Revision$

Author:

fracpete (fracpete at waikato dot ac dot nz)

Constructor Summary

Constructors

Constructor	Description
QueueHelper()

Method Summary

Modifier and Type	Method	Description
static boolean	enqueue(Actor actor, StorageName queue, Object payload)	Queues the payload in the specified queue.
static StorageQueueHandler	getQueue(Actor actor, StorageName queue)	Returns the specified queue.
static boolean	hasQueue(Actor actor, StorageName queue)	Checks whether the specified queue is available.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueHelper

public QueueHelper()

Method Detail

hasQueue

public static boolean hasQueue(Actor actor,
                               StorageName queue)

Checks whether the specified queue is available.

Parameters:

actor - the actor to check for

queue - the name of the queue

Returns:

true if available

getQueue

public static StorageQueueHandler getQueue(Actor actor,
                                           StorageName queue)

Returns the specified queue.

Parameters:

actor - the actor to obtain the queue for

queue - the name of the queue

Returns:

the queue handler, null if not available

enqueue

public static boolean enqueue(Actor actor,
                              StorageName queue,
                              Object payload)

Queues the payload in the specified queue.

Parameters:

actor - the actor to obtain the queue for

queue - the name of the queue

payload - the data to queue

Returns:

true if successfully queued