org.jtoolkit.essence.data
Interface Cluster

All Superinterfaces:

java.io.Closeable, Named, Named.Source, Runs

public interface Cluster
extends Named.Source, Runs, Closeable

Author:

Peter Lawrey

Nested Class Summary

static interface

Cluster.ClusterListener An implementation for ClusterListener can process Events for a cluster.

Nested classes/interfaces inherited from interface org.jtoolkit.essence.utils.Named

Named.ContextSource<T>, Named.MapSource<T>, Named.Source<T>

Field Summary

Fields inherited from interface org.jtoolkit.essence.utils.Named.Source

EMPTY_SOURCE

Fields inherited from interface org.jtoolkit.essence.app.Runs

START

Fields inherited from interface org.jtoolkit.essence.utils.Closeable

CLOSED

Method Summary

java.util.Set<java.lang.String>	getAvailableMasters()
Event.ListenerSet	getListenerSet()
Event.ListenerSet	getListenerSet(java.lang.String collectionName)
<K,V> ClusterMap<K,V>	getMapView(java.lang.String collectionName)
<E> java.util.Queue<E>	getQueueView(java.lang.String collectionName)
<K,V> int	removeMatching(java.lang.String name, Predicate<? super org.jtoolkit.essence.data.impl.MetaData<K,V>> predicate)
<K,V> java.util.Map<K,V>	selectMatching(java.lang.String name, Predicate<? super org.jtoolkit.essence.data.impl.MetaData<K,V>> predicate)

Methods inherited from interface org.jtoolkit.essence.utils.Named.Source

getNames, getValue

Methods inherited from interface org.jtoolkit.essence.utils.Named

getName

Methods inherited from interface org.jtoolkit.essence.app.Runs

start, stop

Methods inherited from interface org.jtoolkit.essence.utils.Closeable

close, isClosed

Method Detail

getListenerSet

Event.ListenerSet getListenerSet()

Returns:

The ListenerSet for this cluster.

getListenerSet

Event.ListenerSet getListenerSet(java.lang.String collectionName)

getQueueView

<E> java.util.Queue<E> getQueueView(java.lang.String collectionName)
                                throws java.lang.IllegalArgumentException,
                                       java.lang.IllegalStateException

Returns:

The Queue representing a collection of a given name.

Throws:

java.lang.IllegalArgumentException - if the collectionName is not defined or is defined incorrectly.

java.lang.IllegalStateException

getMapView

<K,V> ClusterMap<K,V> getMapView(java.lang.String collectionName)
                           throws java.lang.IllegalArgumentException,
                                  java.lang.IllegalStateException

Returns:

The Map representing a collection of a given name.

Throws:

java.lang.IllegalArgumentException - if the collectionName is not defined or is defined incorrectly.

java.lang.IllegalStateException

selectMatching

<K,V> java.util.Map<K,V> selectMatching(java.lang.String name,
                                        Predicate<? super org.jtoolkit.essence.data.impl.MetaData<K,V>> predicate)

Returns:

A collection of values which match the predicate.

removeMatching

<K,V> int removeMatching(java.lang.String name,
                         Predicate<? super org.jtoolkit.essence.data.impl.MetaData<K,V>> predicate)

Returns:

The number of entries removed where the predicate was true.

getAvailableMasters

java.util.Set<java.lang.String> getAvailableMasters()