Class TopicBackingMapManager<D extends TopicDependencies, S extends NamedTopicScheme>

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.AbstractBackingMapManager

com.tangosol.net.ExtensibleConfigurableCacheFactory.Manager

com.tangosol.net.topic.TopicBackingMapManager<D,S>

Type Parameters:

D - the type of the TopicDependencies used

S - the type of the NamedTopicScheme defining the topic

All Implemented Interfaces:

BackingMapManager

public abstract class TopicBackingMapManager<D extends TopicDependencies, S extends NamedTopicScheme>
extends ExtensibleConfigurableCacheFactory.Manager

A base class for topic backing map managers.

Since:

22.09

Author:

Jonathan Knight 2002.09.10

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.util.Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopicBackingMapManager(ExtensibleConfigurableCacheFactory eccf)	Create a TopicBackingMapManager.

Method Summary

Modifier and Type	Method	Description
abstract S	findTopicScheme(String sName)	Find the NamedTopicScheme that defines a topic.
abstract D	getTopicDependencies(String sName)	Get the TopicDependencies for a topic.
protected Map	instantiatePartitionedBackingMap(MapBuilder bldrMap, ParameterResolver resolver, MapBuilder.Dependencies dependencies, CachingScheme scheme)	Instantiate a partitioned backing map (an instance of ObservableSplittingBackingMap) using ExtensibleConfigurableCacheFactory.PartitionedBackingMapManager.

Methods inherited from class com.tangosol.net.ExtensibleConfigurableCacheFactory.Manager

findCachingScheme, findDistributedScheme, getBackingMap, getCacheFactory, getReadLocator, getResolver, getScopedResolver, getStorageAccessAuthorizer, init, instantiateBackingMap, instantiateBackupMap, instantiatePartitionedBackingMap, isBackingMapPersistent, isBackingMapSlidingExpiry, isBackupPartitioned, releaseBackingMap, releaseBackupMap, setBackingMap

Methods inherited from class com.tangosol.net.AbstractBackingMapManager

getContext

Methods inherited from class com.tangosol.util.Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.net.BackingMapManager

isBackingMapPersistent

Constructor Details

TopicBackingMapManager

protected TopicBackingMapManager(ExtensibleConfigurableCacheFactory eccf)

Create a TopicBackingMapManager.

Parameters:

eccf - the owning ExtensibleConfigurableCacheFactory

Method Details

findTopicScheme

public abstract S findTopicScheme(String sName)

Find the NamedTopicScheme that defines a topic.

Parameters:

sName - the name of the topic

Returns:

the NamedTopicScheme that defines the topic

getTopicDependencies

public abstract D getTopicDependencies(String sName)

Get the TopicDependencies for a topic.

Parameters:

sName - the name of the topic

Returns:

the TopicDependencies for the topic

instantiatePartitionedBackingMap

protected Map instantiatePartitionedBackingMap(MapBuilder bldrMap,
 ParameterResolver resolver,
 MapBuilder.Dependencies dependencies,
 CachingScheme scheme)

Description copied from class: ExtensibleConfigurableCacheFactory.Manager

Instantiate a partitioned backing map (an instance of ObservableSplittingBackingMap) using ExtensibleConfigurableCacheFactory.PartitionedBackingMapManager. If the provided scheme is an instance of ReadWriteBackingMapScheme, the internal scheme's map builder is used to build the backing map.

Overrides:

instantiatePartitionedBackingMap in class ExtensibleConfigurableCacheFactory.Manager

Parameters:

bldrMap - the MapBuilder for partitions

resolver - the ParameterizedBuilder

dependencies - the ExtensibleConfigurableCacheFactory.Dependencies for MapBuilders

scheme - the CachingScheme of the requested cache

Returns:

partitioned backing map that will provide backing storage for the specified cache