org.mule.util.queue
Class SerialisationPersistence

java.lang.Object
  extended byorg.mule.util.queue.SerialisationPersistence
All Implemented Interfaces:
PersistenceStrategy

public class SerialisationPersistence
extends java.lang.Object
implements PersistenceStrategy

SerialisationPersistence persists event objects to disk. Requires that the event payload is serializable.

Version:
$Revision: 1.1.1.1 $
Author:
Ross Mason

Nested Class Summary
static class SerialisationPersistence.EventFilenameFilter
           
 
Field Summary
static java.lang.String DEFAULT_QUEUE_STORE
           
protected static Log logger
          logger used by this class
 
Constructor Summary
SerialisationPersistence()
           
 
Method Summary
 void dispose()
           
 java.lang.String getQueueStore()
           
 void initialise(BoundedChannel queue, java.lang.String componentName)
           
 boolean remove(UMOEvent event)
           
 void setQueueStore(java.lang.String queueStore)
           
 void store(UMOEvent event)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_QUEUE_STORE

public static final java.lang.String DEFAULT_QUEUE_STORE

logger

protected static transient Log logger
logger used by this class

Constructor Detail

SerialisationPersistence

public SerialisationPersistence()
Method Detail

store

public void store(UMOEvent event)
           throws PersistentQueueException
Specified by:
store in interface PersistenceStrategy
Throws:
PersistentQueueException

remove

public boolean remove(UMOEvent event)
               throws PersistentQueueException
Specified by:
remove in interface PersistenceStrategy
Throws:
PersistentQueueException

initialise

public void initialise(BoundedChannel queue,
                       java.lang.String componentName)
                throws InitialisationException
Specified by:
initialise in interface PersistenceStrategy
Throws:
InitialisationException

getQueueStore

public java.lang.String getQueueStore()

setQueueStore

public void setQueueStore(java.lang.String queueStore)

dispose

public void dispose()
             throws PersistentQueueException
Specified by:
dispose in interface PersistenceStrategy
Throws:
PersistentQueueException


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