org.mule.modules.mongo

Class MongoObjectStore

java.lang.Object

org.mule.modules.mongo.MongoObjectStore

All Implemented Interfaces:

org.mule.api.context.MuleContextAware, org.mule.api.store.ExpirableObjectStore<Serializable>, org.mule.api.store.ListableObjectStore<Serializable>, org.mule.api.store.ObjectStore<Serializable>, org.mule.api.store.PartitionableExpirableObjectStore<Serializable>, org.mule.api.store.PartitionableObjectStore<Serializable>

public class MongoObjectStore
extends Object
implements org.mule.api.store.PartitionableExpirableObjectStore<Serializable>, org.mule.api.context.MuleContextAware

A PartitionableExpirableObjectStore backed by MongoDB.

Constructor Summary

Constructors

Constructor and Description
MongoObjectStore()

Method Summary

Modifier and Type	Method and Description
List<Serializable>	allKeys()
List<Serializable>	allKeys(String partitionName)
List<String>	allPartitions()
void	clear()
void	clear(String s)
void	close()
void	close(String partitionName)
boolean	contains(Serializable key)
boolean	contains(Serializable key, String partitionName)
void	disposePartition(String partitionName)
void	expire(int entryTtl, int maxEntries)
void	expire(int entryTtl, int ignoredMaxEntries, String partitionName)
String	getDatabase()
String	getHost()
String	getPartitionName()
String	getPassword()
String	getUsername()
void	initialize()
boolean	isPersistent()
void	open()
void	open(String partitionName)
Serializable	remove(Serializable key)
Serializable	remove(Serializable key, String partitionName)
Serializable	retrieve(Serializable key)
Serializable	retrieve(Serializable key, String partitionName)
void	setDatabase(String database)
void	setHost(String host)
void	setMuleContext(org.mule.api.MuleContext context)
void	setPartitionName(String partitionName)
void	setPassword(String password)
void	setUsername(String username)
void	store(Serializable key, Serializable value)
void	store(Serializable key, Serializable value, String partitionName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoObjectStore

public MongoObjectStore()

Method Detail

initialize

@PostConstruct
public void initialize()
                               throws UnknownHostException,
                                      org.mule.api.store.ObjectStoreNotAvaliableException,
                                      org.mule.api.ConnectionException

Throws:

UnknownHostException

org.mule.api.store.ObjectStoreNotAvaliableException

org.mule.api.ConnectionException

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface org.mule.api.store.ObjectStore<Serializable>

open

public void open()
          throws org.mule.api.store.ObjectStoreException

Specified by:

open in interface org.mule.api.store.ListableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

close

public void close()
           throws org.mule.api.store.ObjectStoreException

Specified by:

close in interface org.mule.api.store.ListableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

allKeys

public List<Serializable> allKeys()
                           throws org.mule.api.store.ObjectStoreException

Specified by:

allKeys in interface org.mule.api.store.ListableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

expire

public void expire(int entryTtl,
                   int maxEntries)
            throws org.mule.api.store.ObjectStoreException

Specified by:

expire in interface org.mule.api.store.ExpirableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

contains

public boolean contains(Serializable key)
                 throws org.mule.api.store.ObjectStoreException

Specified by:

contains in interface org.mule.api.store.ObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

store

public void store(Serializable key,
                  Serializable value)
           throws org.mule.api.store.ObjectStoreException

Specified by:

store in interface org.mule.api.store.ObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

retrieve

public Serializable retrieve(Serializable key)
                      throws org.mule.api.store.ObjectStoreException

Specified by:

retrieve in interface org.mule.api.store.ObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

remove

public Serializable remove(Serializable key)
                    throws org.mule.api.store.ObjectStoreException

Specified by:

remove in interface org.mule.api.store.ObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

open

public void open(String partitionName)
          throws org.mule.api.store.ObjectStoreException

Specified by:

open in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

close

public void close(String partitionName)
           throws org.mule.api.store.ObjectStoreException

Specified by:

close in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

contains

public boolean contains(Serializable key,
                        String partitionName)
                 throws org.mule.api.store.ObjectStoreException

Specified by:

contains in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

allKeys

public List<Serializable> allKeys(String partitionName)
                           throws org.mule.api.store.ObjectStoreException

Specified by:

allKeys in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

allPartitions

public List<String> allPartitions()
                           throws org.mule.api.store.ObjectStoreException

Specified by:

allPartitions in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

store

public void store(Serializable key,
                  Serializable value,
                  String partitionName)
           throws org.mule.api.store.ObjectStoreException

Specified by:

store in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

retrieve

public Serializable retrieve(Serializable key,
                             String partitionName)
                      throws org.mule.api.store.ObjectStoreException

Specified by:

retrieve in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

remove

public Serializable remove(Serializable key,
                           String partitionName)
                    throws org.mule.api.store.ObjectStoreException

Specified by:

remove in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

disposePartition

public void disposePartition(String partitionName)
                      throws org.mule.api.store.ObjectStoreException

Specified by:

disposePartition in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

clear

public void clear(String s)
           throws org.mule.api.store.ObjectStoreException

Specified by:

clear in interface org.mule.api.store.PartitionableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

clear

public void clear()
           throws org.mule.api.store.ObjectStoreException

Specified by:

clear in interface org.mule.api.store.ObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

expire

public void expire(int entryTtl,
                   int ignoredMaxEntries,
                   String partitionName)
            throws org.mule.api.store.ObjectStoreException

Specified by:

expire in interface org.mule.api.store.PartitionableExpirableObjectStore<Serializable>

Throws:

org.mule.api.store.ObjectStoreException

getDatabase

public String getDatabase()

setDatabase

public void setDatabase(String database)

getHost

public String getHost()

setHost

public void setHost(String host)

getUsername

public String getUsername()

setUsername

public void setUsername(String username)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

setMuleContext

public void setMuleContext(org.mule.api.MuleContext context)

Specified by:

setMuleContext in interface org.mule.api.context.MuleContextAware

getPartitionName

public String getPartitionName()

setPartitionName

public void setPartitionName(String partitionName)