org.mule.util.queue
Class BoundedPersistentQueue
java.lang.Object
BoundedBuffer
org.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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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.