org.mule.util.store

Class PartitionedInMemoryObjectStore<T extends Serializable>

java.lang.Object

org.mule.util.store.AbstractPartitionedObjectStore<T>

org.mule.util.store.PartitionedInMemoryObjectStore<T>

All Implemented Interfaces:

ExpirableObjectStore<T>, ListableObjectStore<T>, ObjectStore<T>, PartitionableExpirableObjectStore<T>, PartitionableObjectStore<T>

public class PartitionedInMemoryObjectStore<T extends Serializable>
extends AbstractPartitionedObjectStore<T>
implements PartitionableExpirableObjectStore<T>

Field Summary

Fields inherited from class org.mule.util.store.AbstractPartitionedObjectStore

DEFAULT_PARTITION, logger

Constructor Summary

Constructors

Constructor and Description
PartitionedInMemoryObjectStore()

Method Summary

Methods

Modifier and Type	Method and Description
List<Serializable>	allKeys(String partitionName)
List<String>	allPartitions()
void	clear(String partitionName)
void	close(String partitionName)
boolean	contains(Serializable key, String partitionName)
void	disposePartition(String partitionName)
void	expire(int entryTTL, int maxEntries)
void	expire(int entryTTL, int maxEntries, String partitionName)
protected long	getCurrentNanoTime()
boolean	isPersistent() Is this store persistent?
void	open(String partitionName)
T	remove(Serializable key, String partitionName)
T	retrieve(Serializable key, String partitionName)
void	store(Serializable key, T value, String partitionName)

Methods inherited from class org.mule.util.store.AbstractPartitionedObjectStore

allKeys, clear, close, contains, open, remove, retrieve, store

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.api.store.ListableObjectStore

allKeys, close, open

Methods inherited from interface org.mule.api.store.ObjectStore

clear, contains, remove, retrieve, store

Constructor Detail

PartitionedInMemoryObjectStore

public PartitionedInMemoryObjectStore()

Method Detail

isPersistent

public boolean isPersistent()

Description copied from interface: ObjectStore

Is this store persistent?

Specified by:

isPersistent in interface ObjectStore<T extends Serializable>

Returns:

true if this store is persistent

contains

public boolean contains(Serializable key,
               String partitionName)
                 throws ObjectStoreException

Specified by:

contains in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

store

public void store(Serializable key,
         T value,
         String partitionName)
           throws ObjectStoreException

Specified by:

store in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

retrieve

public T retrieve(Serializable key,
         String partitionName)
                                throws ObjectStoreException

Specified by:

retrieve in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

remove

public T remove(Serializable key,
       String partitionName)
                              throws ObjectStoreException

Specified by:

remove in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

allKeys

public List<Serializable> allKeys(String partitionName)
                           throws ObjectStoreException

Specified by:

allKeys in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

clear

public void clear(String partitionName)
           throws ObjectStoreException

Specified by:

clear in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

allPartitions

public List<String> allPartitions()
                           throws ObjectStoreException

Specified by:

allPartitions in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

open

public void open(String partitionName)
          throws ObjectStoreException

Specified by:

open in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

close

public void close(String partitionName)
           throws ObjectStoreException

Specified by:

close in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

expire

public void expire(int entryTTL,
          int maxEntries)
            throws ObjectStoreException

Specified by:

expire in interface ExpirableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

expire

public void expire(int entryTTL,
          int maxEntries,
          String partitionName)
            throws ObjectStoreException

Specified by:

expire in interface PartitionableExpirableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

disposePartition

public void disposePartition(String partitionName)
                      throws ObjectStoreException

Specified by:

disposePartition in interface PartitionableObjectStore<T extends Serializable>

Throws:

ObjectStoreException

getCurrentNanoTime

protected long getCurrentNanoTime()