All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class JavaGroups.Queue

java.lang.Object
   |
   +----JavaGroups.Queue

public class Queue

extends Object

Queue()

Add(Object)

AddAtHead(Object)

Close(boolean)

Marks the queues as closed.

GetContents()

main(String[])

Peek()

Peek(long)

Doesn't remove element

Remove()

Remove(long)

RemoveElement(Object)

Reset()

Size()

toString()

 public Queue()

 public void Add(Object msg) throws QueueClosed

 public void AddAtHead(Object msg) throws QueueClosed

 public Object Remove() throws QueueClosed

 public void RemoveElement(Object element) throws QueueClosed

 public Object Peek() throws QueueClosed

 public Object Remove(long timeout) throws QueueClosed, Timeout

 public Object Peek(long timeout) throws QueueClosed, Timeout

Doesn't remove element

 public synchronized void Close(boolean flush_entries)

Marks the queues as closed. When an Add or Remove operation is attempted on a closed queue, an exception is thrown.

Parameters:

flush_entries - When true, a end-of-entries marker is added to the end of the queue. Entries may be added and removed, but when the end-of-entries marker is encountered, the queue is marked as closed. This allows to flush pending messages before clsing the queue.

 public synchronized void Reset()

 public int Size()

 public String toString()

Overrides:

toString in class Object

 public Vector GetContents()

 public static void main(String args[])

All Packages  Class Hierarchy  This Package  Previous  Next  Index