com.hazelcast.instance

Class DefaultNodeExtension

java.lang.Object

com.hazelcast.instance.DefaultNodeExtension

All Implemented Interfaces:

NodeExtension

public class DefaultNodeExtension
extends Object
implements NodeExtension

Field Summary

Fields

Modifier and Type	Field and Description
protected ILogger	logger
protected Node	node
protected ILogger	systemLogger

Constructor Summary

Constructors

Constructor and Description
DefaultNodeExtension(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
void	afterStart() Called after node is started
void	beforeJoin() Called before node attempts to join to the cluster
void	beforeShutdown() Called before Node.shutdown()
void	beforeStart() Called before node is started
Map<String,Object>	createExtensionServices() Creates additional extension services, which will be registered by service manager during start-up.
ReadHandler	createReadHandler(TcpIpConnection connection, IOService ioService) Creates a ReadHandler for given Connection instance.
SerializationService	createSerializationService() Creates a SerializationService instance to be used by this Node.
<T> T	createService(Class<T> clazz) Creates a service which is an implementation of given type parameter.
WriteHandler	createWriteHandler(TcpIpConnection connection, IOService ioService) Creates a WriteHandler for given Connection instance.
MemberSocketInterceptor	getMemberSocketInterceptor() Returns MemberSocketInterceptor for this Node if available, otherwise returns null.
MemoryStats	getMemoryStats() Returns MemoryStats of for the JVM and current HazelcastInstance.
protected PartitioningStrategy	getPartitioningStrategy(ClassLoader configClassLoader)
SecurityContext	getSecurityContext() Returns SecurityContext for this Node if available, otherwise returns null.
SocketChannelWrapperFactory	getSocketChannelWrapperFactory() Returns SocketChannelWrapperFactory instance to be used by this Node.
boolean	isStartCompleted() Returns true if the instance has started
void	onClusterStateChange(ClusterState newState, boolean persistentChange) Called when cluster state is changed
void	onThreadStart(Thread thread) Called on thread start to inject/intercept extension specific logic, like; registering thread in some service, executing a special method before thread starts to do its own task.
void	onThreadStop(Thread thread) Called before a thread stops to clean/release injected by NodeExtension.onThreadStart(Thread).
void	printNodeInfo() Called to print node information during startup
boolean	registerListener(Object listener) Registers given register if it's a known type.
void	shutdown() Shutdowns NodeExtension.
boolean	triggerForceStart() Forces node to start by skipping hot-restart completely and removing all hot-restart data even if node is still on validation phase or loading hot-restart data.
void	validateJoinRequest() Called before a new node is joining to cluster, executed if node is the master node before join event.

Methods inherited from class java.lang.Object

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

Field Detail

node

protected final Node node

logger

protected final ILogger logger

systemLogger

protected final ILogger systemLogger

Constructor Detail

DefaultNodeExtension

public DefaultNodeExtension(Node node)

Method Detail

beforeStart

public void beforeStart()

Description copied from interface: NodeExtension

Called before node is started

Specified by:

beforeStart in interface NodeExtension

printNodeInfo

public void printNodeInfo()

Description copied from interface: NodeExtension

Called to print node information during startup

Specified by:

printNodeInfo in interface NodeExtension

beforeJoin

public void beforeJoin()

Description copied from interface: NodeExtension

Called before node attempts to join to the cluster

Specified by:

beforeJoin in interface NodeExtension

afterStart

public void afterStart()

Description copied from interface: NodeExtension

Called after node is started

Specified by:

afterStart in interface NodeExtension

isStartCompleted

public boolean isStartCompleted()

Description copied from interface: NodeExtension

Returns true if the instance has started

Specified by:

isStartCompleted in interface NodeExtension

getSecurityContext

public SecurityContext getSecurityContext()

Description copied from interface: NodeExtension

Returns SecurityContext for this Node if available, otherwise returns null.

Specified by:

getSecurityContext in interface NodeExtension

Returns:

security context

createSerializationService

public SerializationService createSerializationService()

Description copied from interface: NodeExtension

Creates a SerializationService instance to be used by this Node.

Specified by:

createSerializationService in interface NodeExtension

Returns:

a SerializationService instance

getPartitioningStrategy

protected PartitioningStrategy getPartitioningStrategy(ClassLoader configClassLoader)
                                                throws Exception

Throws:

Exception

createService

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

Description copied from interface: NodeExtension

Creates a service which is an implementation of given type parameter.

Specified by:

createService in interface NodeExtension

Parameters:

clazz - type of service

Returns:

service implementation

createExtensionServices

public Map<String,Object> createExtensionServices()

Description copied from interface: NodeExtension

Creates additional extension services, which will be registered by service manager during start-up. By default returned map will be empty.

Specified by:

createExtensionServices in interface NodeExtension

Returns:

extension services

getMemberSocketInterceptor

public MemberSocketInterceptor getMemberSocketInterceptor()

Description copied from interface: NodeExtension

Returns MemberSocketInterceptor for this Node if available, otherwise returns null.

Specified by:

getMemberSocketInterceptor in interface NodeExtension

Returns:

MemberSocketInterceptor

getSocketChannelWrapperFactory

public SocketChannelWrapperFactory getSocketChannelWrapperFactory()

Description copied from interface: NodeExtension

Returns SocketChannelWrapperFactory instance to be used by this Node.

Specified by:

getSocketChannelWrapperFactory in interface NodeExtension

Returns:

SocketChannelWrapperFactory

createReadHandler

public ReadHandler createReadHandler(TcpIpConnection connection,
                            IOService ioService)

Description copied from interface: NodeExtension

Creates a ReadHandler for given Connection instance.

Specified by:

createReadHandler in interface NodeExtension

Parameters:

connection - tcp-ip connection

ioService - IOService

Returns:

the created ReadHandler.

createWriteHandler

public WriteHandler createWriteHandler(TcpIpConnection connection,
                              IOService ioService)

Description copied from interface: NodeExtension

Creates a WriteHandler for given Connection instance.

Specified by:

createWriteHandler in interface NodeExtension

Parameters:

connection - tcp-ip connection

ioService - IOService

Returns:

the created WriteHandler

onThreadStart

public void onThreadStart(Thread thread)

Description copied from interface: NodeExtension

Called on thread start to inject/intercept extension specific logic, like; registering thread in some service, executing a special method before thread starts to do its own task.

Specified by:

onThreadStart in interface NodeExtension

Parameters:

thread - thread starting

onThreadStop

public void onThreadStop(Thread thread)

Description copied from interface: NodeExtension

Called before a thread stops to clean/release injected by NodeExtension.onThreadStart(Thread).

Specified by:

onThreadStop in interface NodeExtension

Parameters:

thread - thread stopping

getMemoryStats

public MemoryStats getMemoryStats()

Description copied from interface: NodeExtension

Returns MemoryStats of for the JVM and current HazelcastInstance.

Specified by:

getMemoryStats in interface NodeExtension

Returns:

memory statistics

beforeShutdown

public void beforeShutdown()

Description copied from interface: NodeExtension

Called before Node.shutdown()

Specified by:

beforeShutdown in interface NodeExtension

shutdown

public void shutdown()

Description copied from interface: NodeExtension

Shutdowns NodeExtension. Called on Node.shutdown()

Specified by:

shutdown in interface NodeExtension

validateJoinRequest

public void validateJoinRequest()

Description copied from interface: NodeExtension

Called before a new node is joining to cluster, executed if node is the master node before join event. ClusterJoinManager calls this method, when handleJoinRequest method is called. By this way, we can check the logic we want by implementing this method. Implementation should throw required exception, with a valid message which explains rejection reason.

Specified by:

validateJoinRequest in interface NodeExtension

onClusterStateChange

public void onClusterStateChange(ClusterState newState,
                        boolean persistentChange)

Description copied from interface: NodeExtension

Called when cluster state is changed

Specified by:

onClusterStateChange in interface NodeExtension

Parameters:

newState - new state

persistentChange - status of the change. A cluster state change may be non-persistent if it has been done temporarily during system operations such cluster start etc.

registerListener

public boolean registerListener(Object listener)

Description copied from interface: NodeExtension

Registers given register if it's a known type.

Specified by:

registerListener in interface NodeExtension

Parameters:

listener - listener instance

Returns:

true if listener is registered, false otherwise

triggerForceStart

public boolean triggerForceStart()

Description copied from interface: NodeExtension

Forces node to start by skipping hot-restart completely and removing all hot-restart data even if node is still on validation phase or loading hot-restart data.

Specified by:

triggerForceStart in interface NodeExtension

Returns:

true if hot restart is enabled and this node knows the master