Package com.tangosol.coherence.config.scheme

Class RemoteTopicScheme

java.lang.Object

com.tangosol.coherence.config.scheme.AbstractScheme

com.tangosol.coherence.config.scheme.AbstractServiceScheme<com.tangosol.internal.net.service.extend.remote.RemoteTopicServiceDependencies>

com.tangosol.coherence.config.scheme.AbstractCachingScheme<com.tangosol.internal.net.service.extend.remote.RemoteTopicServiceDependencies>

com.tangosol.coherence.config.scheme.RemoteTopicScheme

All Implemented Interfaces:

BackingMapManagerBuilder, MapBuilder, NamedCacheBuilder, NamedCollectionBuilder<NamedTopic>, ServiceBuilder, CachingScheme, NamedTopicScheme, ObservableCachingScheme, Scheme, ServiceScheme, TopicScheme<NamedTopic,TopicService>

public class RemoteTopicScheme
extends AbstractCachingScheme<com.tangosol.internal.net.service.extend.remote.RemoteTopicServiceDependencies>
implements NamedTopicScheme

The RemoteTopicScheme is responsible for building a remote topic.

Author:

Jonathan Knight 2025.01.01

Nested Class Summary

Nested classes/interfaces inherited from interface com.tangosol.coherence.config.builder.MapBuilder

MapBuilder.Dependencies

Field Summary

Fields inherited from class com.tangosol.coherence.config.scheme.AbstractServiceScheme

m_serviceDependencies

Fields inherited from interface com.tangosol.coherence.config.scheme.ServiceScheme

DELIM_APPLICATION_SCOPE, DELIM_DOMAIN_PARTITION

Constructor Summary

Constructors

Constructor	Description
RemoteTopicScheme()	Constructs a RemoteTopicScheme.

Method Summary

Modifier and Type	Method	Description
TopicDependencies	createConfiguration(ParameterResolver resolver, ClassLoader loader)	Create a TopicDependencies based on the values contained in this scheme.
TopicService	ensureConfiguredService(ParameterResolver resolver, MapBuilder.Dependencies deps)	Obtain a configured topic service.
RemoteTopicScheme	getNamedCollectionBuilder(Class<? extends NamedCollection> clz, com.oracle.coherence.common.util.Options<NamedCollection.Option> options)
String	getServiceType()	Return the service type.
boolean	isRunningClusterNeeded()	Return true if a running cluster is needed before using a service.
<V> NamedTopic	realize(ValueTypeAssertion<V> typeConstraint, ParameterResolver resolver, MapBuilder.Dependencies deps)	Realizes a NamedCollection (possibly "ensuring it") based on the state of the builder, the provided ParameterResolver and MapBuilder dependencies.
<T extends NamedCollection> boolean	realizes(Class<T> type)	Determines whether this NamedCollectionBuilder can realize a NamedCollection of the specified type.
Service	realizeService(ParameterResolver resolver, ClassLoader loader, Cluster cluster)	Realize (ensure) a Service.

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractCachingScheme

establishMapListeners, getDefaultParameterResolver, getListenerBuilder, realizeBackingMapManager, realizeCache, realizeMap, setListenerBuilder, validate

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractServiceScheme

ensureService, getDefaultServiceName, getEventInterceptorBuilders, getScopedServiceName, getScopeName, getServiceBuilder, getServiceDependencies, getServiceName, getXml, injectScopeNameIntoService, isAutoStart, setAutoStart, setScopeName, setServiceDependencies, setServiceName, setXml

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractScheme

getSchemeName, isAnonymous, setSchemeName, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.coherence.config.scheme.Scheme

getSchemeName, isAnonymous

Methods inherited from interface com.tangosol.coherence.config.scheme.ServiceScheme

getEventInterceptorBuilders, getScopedServiceName, getScopedServiceNameForProperty, getServiceBuilder, getServiceName, isAutoStart

Constructor Details

RemoteTopicScheme

public RemoteTopicScheme()

Constructs a RemoteTopicScheme.

Method Details

getServiceType

public String getServiceType()

Return the service type.

Specified by:

getServiceType in interface ServiceScheme

Returns:

the service type

isRunningClusterNeeded

public boolean isRunningClusterNeeded()

Description copied from class: AbstractServiceScheme

Return true if a running cluster is needed before using a service.

Specified by:

isRunningClusterNeeded in interface ServiceBuilder

Specified by:

isRunningClusterNeeded in class AbstractServiceScheme<com.tangosol.internal.net.service.extend.remote.RemoteTopicServiceDependencies>

Returns:

true if a running cluster is needed before using a service

realizeService

public Service realizeService(ParameterResolver resolver,
 ClassLoader loader,
 Cluster cluster)

Description copied from class: AbstractServiceScheme

Realize (ensure) a Service. The returned Service is fully configured and ready to be used.

Specified by:

realizeService in interface ServiceBuilder

Overrides:

realizeService in class AbstractServiceScheme<com.tangosol.internal.net.service.extend.remote.RemoteTopicServiceDependencies>

Parameters:

resolver - the ParameterResolver

loader - the ClassLoader

cluster - the Cluster which will already be running if necessary

Returns:

the Service

getNamedCollectionBuilder

public RemoteTopicScheme getNamedCollectionBuilder(Class<? extends NamedCollection> clz,
 com.oracle.coherence.common.util.Options<NamedCollection.Option> options)

Specified by:

getNamedCollectionBuilder in interface ServiceScheme

createConfiguration

public TopicDependencies createConfiguration(ParameterResolver resolver,
 ClassLoader loader)

Description copied from interface: TopicScheme

Create a TopicDependencies based on the values contained in this scheme.

Specified by:

createConfiguration in interface TopicScheme<NamedTopic,TopicService>

Parameters:

resolver - the ParameterResolver to use to resolve configuration values

loader - the ClassLoader to use

Returns:

a TopicDependencies based on the values contained in this scheme

ensureConfiguredService

public TopicService ensureConfiguredService(ParameterResolver resolver,
 MapBuilder.Dependencies deps)

Description copied from interface: TopicScheme

Obtain a configured topic service.

Specified by:

ensureConfiguredService in interface TopicScheme<NamedTopic,TopicService>

Parameters:

resolver - the ParameterResolver to use to resolve the service parameters

deps - the dependencies to use to configure the service

Returns:

a configured topic service

realize

public <V> NamedTopic realize(ValueTypeAssertion<V> typeConstraint,
 ParameterResolver resolver,
 MapBuilder.Dependencies deps)

Description copied from interface: NamedCollectionBuilder

Realizes a NamedCollection (possibly "ensuring it") based on the state of the builder, the provided ParameterResolver and MapBuilder dependencies.

The MapBuilder dependencies are required to satisfy the requirement when realizing a NamedCollection additionally involves realizing one or more internal Maps.

Specified by:

realize in interface NamedCollectionBuilder<NamedTopic>

Type Parameters:

V - the element type of NamedCollection

Parameters:

typeConstraint - type constraint assertion for elements of this NamedCollection

resolver - the ParameterResolver

deps - the MapBuilder dependencies

Returns:

a NamedCollection

realizes

public <T extends NamedCollection> boolean realizes(Class<T> type)

Description copied from interface: NamedCollectionBuilder

Determines whether this NamedCollectionBuilder can realize a NamedCollection of the specified type.

Specified by:

realizes in interface NamedCollectionBuilder<NamedTopic>

Type Parameters:

T - the type of the class to verify

Parameters:

type - the Class of the type to verify

Returns:

true if this builder can realize a NamedCollection of the specified type.