org.mule.util.queue
Class BoundedPersistentQueue

java.lang.Object
  extended byBoundedBuffer
      extended byorg.mule.util.queue.BoundedPersistentQueue
All Implemented Interfaces:
Disposable

public class BoundedPersistentQueue
extends BoundedBuffer
implements Disposable

BoundedPersistentQueue is a UMOEvent queue implementation that can automatically persist events when they are queue.

Version:
$Revision: 1.1.1.1 $
Author:
Ross Mason
See Also:
UMOEvent, Serialized Form

Constructor Summary
BoundedPersistentQueue(int i)
           
BoundedPersistentQueue(int i, PersistenceStrategy ps, java.lang.String name, boolean deleteOnTake)
           
 
Method Summary
 void dispose()
           
 PersistenceStrategy getPersistenceStrategy()
           
 boolean isDeleteOnTake()
           
 void put(java.lang.Object o)
           
 boolean remove(java.lang.Object o)
           
 void setDeleteOnTake(boolean deleteOnTake)
           
 java.lang.Object take()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BoundedPersistentQueue

public BoundedPersistentQueue(int i)
                       throws java.lang.IllegalArgumentException

BoundedPersistentQueue

public BoundedPersistentQueue(int i,
                              PersistenceStrategy ps,
                              java.lang.String name,
                              boolean deleteOnTake)
                       throws java.lang.IllegalArgumentException,
                              InitialisationException
Method Detail

put

public void put(java.lang.Object o)
         throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

take

public java.lang.Object take()
                      throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

remove

public boolean remove(java.lang.Object o)
               throws PersistentQueueException
Throws:
PersistentQueueException

isDeleteOnTake

public boolean isDeleteOnTake()

setDeleteOnTake

public void setDeleteOnTake(boolean deleteOnTake)

getPersistenceStrategy

public PersistenceStrategy getPersistenceStrategy()

dispose

public void dispose()
             throws UMOException
Specified by:
dispose in interface Disposable
Throws:
UMOException


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.