com.mulesoft.mule.runtime.module.cluster.internal

Class HazelcastObjectStore<T extends Serializable>

java.lang.Object

org.mule.runtime.api.store.AbstractObjectStoreSupport<T>

org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T>

com.mulesoft.mule.runtime.module.cluster.internal.HazelcastObjectStore<T>

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.store.ObjectStore<T>, org.mule.runtime.api.store.PartitionableObjectStore<T>, org.mule.runtime.core.api.context.MuleContextAware

public class HazelcastObjectStore<T extends Serializable>
extends org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T>
implements org.mule.runtime.core.api.context.MuleContextAware, org.mule.runtime.api.lifecycle.Disposable

A distributed object map that uses Hazelcast. All operations are a this cover on top of the native Hazelcast distributed map (IMap). Partitions are implemented as separate IMaps

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALL_PARTITIONS_MAP_NAME
protected String	appName
static String	DEFAULT_PARTITION_NAME
protected com.hazelcast.core.HazelcastInstance	instance
protected org.mule.runtime.core.api.MuleContext	muleContext
static String	PARTITION_MAP_NAME
protected boolean	running

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
HazelcastObjectStore(com.hazelcast.core.HazelcastInstance instance) Create an object store for the specified Mule application

Method Summary

Modifier and Type	Method and Description
List<String>	allKeys()
List<String>	allKeys(String partitionName)
List<String>	allPartitions()
void	clear()
void	clear(String partitionName)
void	close()
void	close(String partitionName)
boolean	contains(String key)
void	dispose()
void	disposePartition(String partitionName)
protected boolean	doContains(String key, String partitionName)
protected T	doRemove(String key, String partitionName)
protected T	doRetrieve(String key, String partitionName)
protected void	doStore(String key, T value, String partitionName)
static String	getObjectStorePrefix(String appName)
boolean	isPersistent()
void	open()
void	open(String storeName)
T	remove(String key)
T	retrieve(String key)
Map<String,T>	retrieveAll()
Map<String,T>	retrieveAll(String partitionName)
void	setMuleContext(org.mule.runtime.core.api.MuleContext muleContext)
void	store(String key, T value)

Methods inherited from class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore

contains, remove, retrieve, shouldAlwaysExpire, store, validateKeyAndPartitionName, validatePresentKeyInPartition

Methods inherited from class org.mule.runtime.api.store.AbstractObjectStoreSupport

validateKey, validatePresentKey

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PARTITION_NAME

public static final String DEFAULT_PARTITION_NAME

See Also:

Constant Field Values

ALL_PARTITIONS_MAP_NAME

public static final String ALL_PARTITIONS_MAP_NAME

See Also:

Constant Field Values

PARTITION_MAP_NAME

public static final String PARTITION_MAP_NAME

See Also:

Constant Field Values

muleContext

protected org.mule.runtime.core.api.MuleContext muleContext

instance

protected com.hazelcast.core.HazelcastInstance instance

appName

protected String appName

running

protected boolean running

Constructor Detail

HazelcastObjectStore

public HazelcastObjectStore(com.hazelcast.core.HazelcastInstance instance)

Create an object store for the specified Mule application

Method Detail

getObjectStorePrefix

public static String getObjectStorePrefix(String appName)

setMuleContext

public void setMuleContext(org.mule.runtime.core.api.MuleContext muleContext)

Specified by:

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

open

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

Specified by:

open in interface org.mule.runtime.api.store.ObjectStore<T extends Serializable>

Overrides:

open in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

close

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

Specified by:

close in interface org.mule.runtime.api.store.ObjectStore<T extends Serializable>

Overrides:

close in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

allKeys

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

Specified by:

allKeys in interface org.mule.runtime.api.store.ObjectStore<T extends Serializable>

Overrides:

allKeys in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

retrieveAll

public Map<String,T> retrieveAll()
                          throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

retrieveAll in interface org.mule.runtime.api.store.ObjectStore<T extends Serializable>

Overrides:

retrieveAll in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

contains

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

Specified by:

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

Overrides:

contains in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

clear

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

Specified by:

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

Overrides:

clear in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

store

public void store(String key,
                  T value)
           throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

store in interface org.mule.runtime.api.store.ObjectStore<T extends Serializable>

Overrides:

store in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

retrieve

public T retrieve(String key)
           throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

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

Overrides:

retrieve in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

remove

public T remove(String key)
         throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

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

Overrides:

remove in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

isPersistent

public boolean isPersistent()

Specified by:

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

open

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

doContains

protected boolean doContains(String key,
                             String partitionName)
                      throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

doContains in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

doStore

protected void doStore(String key,
                       T value,
                       String partitionName)
                throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

doStore in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

doRetrieve

protected T doRetrieve(String key,
                       String partitionName)
                throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

doRetrieve in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

clear

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

doRemove

protected T doRemove(String key,
                     String partitionName)
              throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

doRemove in class org.mule.runtime.core.internal.store.AbstractPartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

allKeys

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

retrieveAll

public Map<String,T> retrieveAll(String partitionName)
                          throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

retrieveAll in interface org.mule.runtime.api.store.PartitionableObjectStore<T extends Serializable>

Throws:

org.mule.runtime.api.store.ObjectStoreException

allPartitions

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

close

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

disposePartition

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

Specified by:

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

Throws:

org.mule.runtime.api.store.ObjectStoreException

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.api.lifecycle.Disposable