com.hazelcast.instance

Class EnterpriseNodeExtension

java.lang.Object

com.hazelcast.instance.DefaultNodeExtension

com.hazelcast.instance.EnterpriseNodeExtension

All Implemented Interfaces:

com.hazelcast.instance.NodeExtension, com.hazelcast.internal.metrics.MetricsProvider

public class EnterpriseNodeExtension
extends com.hazelcast.instance.DefaultNodeExtension
implements com.hazelcast.instance.NodeExtension, com.hazelcast.internal.metrics.MetricsProvider

This class is the enterprise system hook to allow injection of enterprise services into Hazelcast subsystems.

Field Summary

Fields inherited from class com.hazelcast.instance.DefaultNodeExtension

clusterVersionListeners, logger, node, phoneHome, systemLogger

Constructor Summary

Constructors

Constructor and Description
EnterpriseNodeExtension(com.hazelcast.instance.Node node)

Method Summary

Modifier and Type	Method and Description
void	afterStart()
void	beforeJoin()
void	beforeShutdown()
void	beforeStart()
protected void	createAndSetPhoneHome()
com.hazelcast.internal.networking.ChannelInitializer	createChannelInitializer(com.hazelcast.nio.IOService ioService)
com.hazelcast.internal.dynamicconfig.DynamicConfigListener	createDynamicConfigListener()
Map<String,Object>	createExtensionServices()
com.hazelcast.internal.networking.InboundHandler[]	createInboundHandlers(com.hazelcast.nio.tcp.TcpIpConnection connection, com.hazelcast.nio.IOService ioService)
com.hazelcast.internal.jmx.ManagementService	createJMXManagementService(com.hazelcast.instance.HazelcastInstanceImpl instance)
String	createMemberUuid(com.hazelcast.nio.Address address)
com.hazelcast.util.ByteArrayProcessor	createMulticastInputProcessor(com.hazelcast.nio.IOService ioService)
com.hazelcast.util.ByteArrayProcessor	createMulticastOutputProcessor(com.hazelcast.nio.IOService ioService)
com.hazelcast.internal.networking.OutboundHandler[]	createOutboundHandlers(com.hazelcast.nio.tcp.TcpIpConnection connection, com.hazelcast.nio.IOService ioService)
com.hazelcast.internal.serialization.InternalSerializationService	createSerializationService()
<T> T	createService(Class<T> clazz)
com.hazelcast.internal.ascii.TextCommandService	createTextCommandService()
com.hazelcast.internal.management.TimedMemberStateFactory	createTimedMemberStateFactory(com.hazelcast.instance.HazelcastInstanceImpl instance)
com.hazelcast.hotrestart.HotRestartService	getHotRestartService()
com.hazelcast.hotrestart.InternalHotRestartService	getInternalHotRestartService()
com.hazelcast.license.domain.License	getLicense()
com.hazelcast.internal.management.ManagementCenterConnectionFactory	getManagementCenterConnectionFactory()
com.hazelcast.nio.MemberSocketInterceptor	getMemberSocketInterceptor()
com.hazelcast.memory.HazelcastMemoryManager	getMemoryManager()
com.hazelcast.memory.MemoryStats	getMemoryStats()
com.hazelcast.security.SecurityContext	getSecurityContext()
com.hazelcast.security.SecurityService	getSecurityService()
boolean	isFeatureEnabledForLicenseKey(com.hazelcast.license.domain.Feature feature)
boolean	isHotRestartEnabled()
boolean	isNodeVersionCompatibleWith(com.hazelcast.version.Version clusterVersion) Check if this node's version is compatible with given cluster version.
boolean	isStartCompleted()
void	onClusterStateChange(com.hazelcast.cluster.ClusterState newState, boolean isTransient)
void	onClusterVersionChange(com.hazelcast.version.Version newVersion)
void	onMemberListChange()
void	onPartitionStateChange()
void	onThreadStart(Thread thread)
void	onThreadStop(Thread thread)
void	printNodeInfo()
void	provideMetrics(com.hazelcast.internal.metrics.MetricsRegistry registry)
boolean	registerListener(Object listener)
void	registerPlugins(com.hazelcast.internal.diagnostics.Diagnostics diagnostics)
void	shutdown()
void	validateJoinRequest(com.hazelcast.internal.cluster.impl.JoinMessage joinRequest)

Methods inherited from class com.hazelcast.instance.DefaultNodeExtension

afterClusterStateChange, beforeClusterStateChange, getPartitioningStrategy, sendPhoneHome

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.instance.NodeExtension

afterClusterStateChange, beforeClusterStateChange, sendPhoneHome

Constructor Detail

EnterpriseNodeExtension

public EnterpriseNodeExtension(com.hazelcast.instance.Node node)

Method Detail

beforeStart

public void beforeStart()

Specified by:

beforeStart in interface com.hazelcast.instance.NodeExtension

Overrides:

beforeStart in class com.hazelcast.instance.DefaultNodeExtension

beforeJoin

public void beforeJoin()

Specified by:

beforeJoin in interface com.hazelcast.instance.NodeExtension

Overrides:

beforeJoin in class com.hazelcast.instance.DefaultNodeExtension

printNodeInfo

public void printNodeInfo()

Specified by:

printNodeInfo in interface com.hazelcast.instance.NodeExtension

Overrides:

printNodeInfo in class com.hazelcast.instance.DefaultNodeExtension

afterStart

public void afterStart()

Specified by:

afterStart in interface com.hazelcast.instance.NodeExtension

Overrides:

afterStart in class com.hazelcast.instance.DefaultNodeExtension

isStartCompleted

public boolean isStartCompleted()

Specified by:

isStartCompleted in interface com.hazelcast.instance.NodeExtension

Overrides:

isStartCompleted in class com.hazelcast.instance.DefaultNodeExtension

getLicense

public com.hazelcast.license.domain.License getLicense()

createSerializationService

public com.hazelcast.internal.serialization.InternalSerializationService createSerializationService()

Specified by:

createSerializationService in interface com.hazelcast.instance.NodeExtension

Overrides:

createSerializationService in class com.hazelcast.instance.DefaultNodeExtension

getSecurityContext

public com.hazelcast.security.SecurityContext getSecurityContext()

Specified by:

getSecurityContext in interface com.hazelcast.instance.NodeExtension

Overrides:

getSecurityContext in class com.hazelcast.instance.DefaultNodeExtension

getSecurityService

public com.hazelcast.security.SecurityService getSecurityService()

Specified by:

getSecurityService in interface com.hazelcast.instance.NodeExtension

Overrides:

getSecurityService in class com.hazelcast.instance.DefaultNodeExtension

getMemberSocketInterceptor

public com.hazelcast.nio.MemberSocketInterceptor getMemberSocketInterceptor()

Specified by:

getMemberSocketInterceptor in interface com.hazelcast.instance.NodeExtension

Overrides:

getMemberSocketInterceptor in class com.hazelcast.instance.DefaultNodeExtension

createInboundHandlers

public com.hazelcast.internal.networking.InboundHandler[] createInboundHandlers(com.hazelcast.nio.tcp.TcpIpConnection connection,
                                                                                com.hazelcast.nio.IOService ioService)

Specified by:

createInboundHandlers in interface com.hazelcast.instance.NodeExtension

Overrides:

createInboundHandlers in class com.hazelcast.instance.DefaultNodeExtension

createOutboundHandlers

public com.hazelcast.internal.networking.OutboundHandler[] createOutboundHandlers(com.hazelcast.nio.tcp.TcpIpConnection connection,
                                                                                  com.hazelcast.nio.IOService ioService)

Specified by:

createOutboundHandlers in interface com.hazelcast.instance.NodeExtension

Overrides:

createOutboundHandlers in class com.hazelcast.instance.DefaultNodeExtension

createChannelInitializer

public com.hazelcast.internal.networking.ChannelInitializer createChannelInitializer(com.hazelcast.nio.IOService ioService)

Specified by:

createChannelInitializer in interface com.hazelcast.instance.NodeExtension

Overrides:

createChannelInitializer in class com.hazelcast.instance.DefaultNodeExtension

onThreadStart

public void onThreadStart(Thread thread)

Specified by:

onThreadStart in interface com.hazelcast.instance.NodeExtension

Overrides:

onThreadStart in class com.hazelcast.instance.DefaultNodeExtension

onThreadStop

public void onThreadStop(Thread thread)

Specified by:

onThreadStop in interface com.hazelcast.instance.NodeExtension

Overrides:

onThreadStop in class com.hazelcast.instance.DefaultNodeExtension

getInternalHotRestartService

public com.hazelcast.hotrestart.InternalHotRestartService getInternalHotRestartService()

Specified by:

getInternalHotRestartService in interface com.hazelcast.instance.NodeExtension

Overrides:

getInternalHotRestartService in class com.hazelcast.instance.DefaultNodeExtension

isHotRestartEnabled

public boolean isHotRestartEnabled()

isFeatureEnabledForLicenseKey

public boolean isFeatureEnabledForLicenseKey(com.hazelcast.license.domain.Feature feature)

beforeShutdown

public void beforeShutdown()

Specified by:

beforeShutdown in interface com.hazelcast.instance.NodeExtension

Overrides:

beforeShutdown in class com.hazelcast.instance.DefaultNodeExtension

shutdown

public void shutdown()

Specified by:

shutdown in interface com.hazelcast.instance.NodeExtension

Overrides:

shutdown in class com.hazelcast.instance.DefaultNodeExtension

createService

public <T> T createService(Class<T> clazz)

Specified by:

createService in interface com.hazelcast.instance.NodeExtension

Overrides:

createService in class com.hazelcast.instance.DefaultNodeExtension

createExtensionServices

public Map<String,Object> createExtensionServices()

Specified by:

createExtensionServices in interface com.hazelcast.instance.NodeExtension

Overrides:

createExtensionServices in class com.hazelcast.instance.DefaultNodeExtension

getMemoryStats

public com.hazelcast.memory.MemoryStats getMemoryStats()

Specified by:

getMemoryStats in interface com.hazelcast.instance.NodeExtension

Overrides:

getMemoryStats in class com.hazelcast.instance.DefaultNodeExtension

validateJoinRequest

public void validateJoinRequest(com.hazelcast.internal.cluster.impl.JoinMessage joinRequest)

Specified by:

validateJoinRequest in interface com.hazelcast.instance.NodeExtension

Overrides:

validateJoinRequest in class com.hazelcast.instance.DefaultNodeExtension

isNodeVersionCompatibleWith

public boolean isNodeVersionCompatibleWith(com.hazelcast.version.Version clusterVersion)

Check if this node's version is compatible with given cluster version. By default, For rolling upgrades context, a node's version is considered compatible with cluster of same version or if cluster's minor version number is smaller by one versus node's minor version number. Each version may overwrite it though by modifying this method.

E.g.: 3.8 does not support any emulation at all. So it's compatible with 3.8 clusters only. 3.9 will be compatible with 3.8 and 3.9 cluster -> if not overwritten in 3.9 codebase.

Specified by:

isNodeVersionCompatibleWith in interface com.hazelcast.instance.NodeExtension

Overrides:

isNodeVersionCompatibleWith in class com.hazelcast.instance.DefaultNodeExtension

Parameters:

clusterVersion - the cluster version to check against

Returns:

true if compatible, otherwise false.

onClusterStateChange

public void onClusterStateChange(com.hazelcast.cluster.ClusterState newState,
                                 boolean isTransient)

Specified by:

onClusterStateChange in interface com.hazelcast.instance.NodeExtension

Overrides:

onClusterStateChange in class com.hazelcast.instance.DefaultNodeExtension

onPartitionStateChange

public void onPartitionStateChange()

Specified by:

onPartitionStateChange in interface com.hazelcast.instance.NodeExtension

Overrides:

onPartitionStateChange in class com.hazelcast.instance.DefaultNodeExtension

onMemberListChange

public void onMemberListChange()

Specified by:

onMemberListChange in interface com.hazelcast.instance.NodeExtension

Overrides:

onMemberListChange in class com.hazelcast.instance.DefaultNodeExtension

onClusterVersionChange

public void onClusterVersionChange(com.hazelcast.version.Version newVersion)

Specified by:

onClusterVersionChange in interface com.hazelcast.instance.NodeExtension

Overrides:

onClusterVersionChange in class com.hazelcast.instance.DefaultNodeExtension

registerListener

public boolean registerListener(Object listener)

Specified by:

registerListener in interface com.hazelcast.instance.NodeExtension

Overrides:

registerListener in class com.hazelcast.instance.DefaultNodeExtension

getMemoryManager

public com.hazelcast.memory.HazelcastMemoryManager getMemoryManager()

getHotRestartService

public com.hazelcast.hotrestart.HotRestartService getHotRestartService()

Specified by:

getHotRestartService in interface com.hazelcast.instance.NodeExtension

Overrides:

getHotRestartService in class com.hazelcast.instance.DefaultNodeExtension

createMemberUuid

public String createMemberUuid(com.hazelcast.nio.Address address)

Specified by:

createMemberUuid in interface com.hazelcast.instance.NodeExtension

Overrides:

createMemberUuid in class com.hazelcast.instance.DefaultNodeExtension

provideMetrics

public void provideMetrics(com.hazelcast.internal.metrics.MetricsRegistry registry)

Specified by:

provideMetrics in interface com.hazelcast.internal.metrics.MetricsProvider

createTimedMemberStateFactory

public com.hazelcast.internal.management.TimedMemberStateFactory createTimedMemberStateFactory(com.hazelcast.instance.HazelcastInstanceImpl instance)

Specified by:

createTimedMemberStateFactory in interface com.hazelcast.instance.NodeExtension

Overrides:

createTimedMemberStateFactory in class com.hazelcast.instance.DefaultNodeExtension

getManagementCenterConnectionFactory

public com.hazelcast.internal.management.ManagementCenterConnectionFactory getManagementCenterConnectionFactory()

Specified by:

getManagementCenterConnectionFactory in interface com.hazelcast.instance.NodeExtension

Overrides:

getManagementCenterConnectionFactory in class com.hazelcast.instance.DefaultNodeExtension

createMulticastInputProcessor

public com.hazelcast.util.ByteArrayProcessor createMulticastInputProcessor(com.hazelcast.nio.IOService ioService)

Specified by:

createMulticastInputProcessor in interface com.hazelcast.instance.NodeExtension

Overrides:

createMulticastInputProcessor in class com.hazelcast.instance.DefaultNodeExtension

createMulticastOutputProcessor

public com.hazelcast.util.ByteArrayProcessor createMulticastOutputProcessor(com.hazelcast.nio.IOService ioService)

Specified by:

createMulticastOutputProcessor in interface com.hazelcast.instance.NodeExtension

Overrides:

createMulticastOutputProcessor in class com.hazelcast.instance.DefaultNodeExtension

registerPlugins

public void registerPlugins(com.hazelcast.internal.diagnostics.Diagnostics diagnostics)

Specified by:

registerPlugins in interface com.hazelcast.instance.NodeExtension

Overrides:

registerPlugins in class com.hazelcast.instance.DefaultNodeExtension

createDynamicConfigListener

public com.hazelcast.internal.dynamicconfig.DynamicConfigListener createDynamicConfigListener()

Specified by:

createDynamicConfigListener in interface com.hazelcast.instance.NodeExtension

Overrides:

createDynamicConfigListener in class com.hazelcast.instance.DefaultNodeExtension

createJMXManagementService

public com.hazelcast.internal.jmx.ManagementService createJMXManagementService(com.hazelcast.instance.HazelcastInstanceImpl instance)

Specified by:

createJMXManagementService in interface com.hazelcast.instance.NodeExtension

Overrides:

createJMXManagementService in class com.hazelcast.instance.DefaultNodeExtension

createTextCommandService

public com.hazelcast.internal.ascii.TextCommandService createTextCommandService()

Specified by:

createTextCommandService in interface com.hazelcast.instance.NodeExtension

Overrides:

createTextCommandService in class com.hazelcast.instance.DefaultNodeExtension

createAndSetPhoneHome

protected void createAndSetPhoneHome()

Overrides:

createAndSetPhoneHome in class com.hazelcast.instance.DefaultNodeExtension