Package org.apache.ignite.internal.processors.subscription

Class GridInternalSubscriptionProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.subscription.GridInternalSubscriptionProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridInternalSubscriptionProcessor
extends GridProcessorAdapter

Processor enables grid components to register listeners for events generated by other components on local node. It starts very first during node startup procedure so any components could use it. As only local events are supported, no network communication occurs during notification process.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
GridInternalSubscriptionProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
List<DatabaseLifecycleListener>	getDatabaseListeners()
List<DistributedConfigurationLifecycleListener>	getDistributedConfigurationListeners()
List<DistributedMetastorageLifecycleListener>	getDistributedMetastorageSubscribers()
List<IgniteChangeGlobalStateSupport>	getGlobalStateListeners()
List<MetastorageLifecycleListener>	getMetastorageSubscribers()
List<SchemaChangeListener>	getSchemaChangeSubscribers()
void	registerDatabaseListener(@NotNull DatabaseLifecycleListener databaseListener)
void	registerDistributedConfigurationListener(@NotNull DistributedConfigurationLifecycleListener lifecycleListener)
void	registerDistributedMetastorageListener(@NotNull DistributedMetastorageLifecycleListener lsnr)
void	registerGlobalStateListener(@NotNull IgniteChangeGlobalStateSupport globalStateListener)
void	registerMetastorageListener(@NotNull MetastorageLifecycleListener metastorageListener)
void	registerSchemaChangeListener(@NotNull SchemaChangeListener schemaChangeListener)

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridInternalSubscriptionProcessor

public GridInternalSubscriptionProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

registerMetastorageListener

public void registerMetastorageListener(@NotNull
                                        @NotNull MetastorageLifecycleListener metastorageListener)

getMetastorageSubscribers

public List<MetastorageLifecycleListener> getMetastorageSubscribers()

registerSchemaChangeListener

public void registerSchemaChangeListener(@NotNull
                                         @NotNull SchemaChangeListener schemaChangeListener)

getSchemaChangeSubscribers

public List<SchemaChangeListener> getSchemaChangeSubscribers()

registerDistributedMetastorageListener

public void registerDistributedMetastorageListener(@NotNull
                                                   @NotNull DistributedMetastorageLifecycleListener lsnr)

getDistributedMetastorageSubscribers

public List<DistributedMetastorageLifecycleListener> getDistributedMetastorageSubscribers()

registerDatabaseListener

public void registerDatabaseListener(@NotNull
                                     @NotNull DatabaseLifecycleListener databaseListener)

getDatabaseListeners

public List<DatabaseLifecycleListener> getDatabaseListeners()

registerDistributedConfigurationListener

public void registerDistributedConfigurationListener(@NotNull
                                                     @NotNull DistributedConfigurationLifecycleListener lifecycleListener)

getDistributedConfigurationListeners

public List<DistributedConfigurationLifecycleListener> getDistributedConfigurationListeners()

registerGlobalStateListener

public void registerGlobalStateListener(@NotNull
                                        @NotNull IgniteChangeGlobalStateSupport globalStateListener)

getGlobalStateListeners

public List<IgniteChangeGlobalStateSupport> getGlobalStateListeners()