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.5 $
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()
          A lifecycle method where implementor should fee up any resources If an exception is thrown it should just be logged and processing should continue.
 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()
Description copied from interface: Disposable
A lifecycle method where implementor should fee up any resources If an exception is thrown it should just be logged and processing should continue. This method should not throw Runtime exceptions

Specified by:
dispose in interface Disposable


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