NodeEngineImpl (Hazelcast Root 3.11 API)

java.lang.Object
- com.hazelcast.spi.impl.NodeEngineImpl

All Implemented Interfaces:

NodeEngine
```
public class NodeEngineImpl
extends Object
implements NodeEngine
```
The NodeEngineImpl is the where the construction of the Hazelcast dependencies take place. It can be compared to a Spring ApplicationContext. It is fine that we refer to concrete types, and it is fine that we cast to a concrete type within this class (e.g. to call shutdown). In an application context you get exactly the same behavior.
But the crucial thing is that we don't want to leak concrete dependencies to the outside. For example we don't leak OperationServiceImpl to the outside.

Constructor Summary

Constructors
Constructor and Description

NodeEngineImpl(Node node)

Constructors
Constructor and Description
`NodeEngineImpl(Node node)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ClusterService`	`getClusterService()` Gets the ClusterService.
`Config`	`getConfig()` Returns the Config that was used to create the HazelcastInstance.
`ClassLoader`	`getConfigClassLoader()` Returns the Config ClassLoader.
`ClusterWideConfigurationService`	`getConfigurationService()`
`Diagnostics`	`getDiagnostics()`
`InternalEventService`	`getEventService()` Gets the EventService.
`InternalExecutionService`	`getExecutionService()` Gets the ExecutionService.
`HazelcastInstance`	`getHazelcastInstance()` Returns the HazelcastInstance that this `NodeEngine` belongs to.
`MemberImpl`	`getLocalMember()` Returns the local member.
`ILogger`	`getLogger(Class clazz)` Gets the logger for a given class.
`ILogger`	`getLogger(String name)` Gets the logger for a given name.
`LoggingService`	`getLoggingService()`
`ManagementCenterService`	`getManagementCenterService()`
`Address`	`getMasterAddress()` Gets the address of the master member.
`MetricsRegistry`	`getMetricsRegistry()`
`Node`	`getNode()`
`OperationParker`	`getOperationParker()`
`InternalOperationService`	`getOperationService()` Gets the OperationService.
`Consumer<Packet>`	`getPacketDispatcher()`
`InternalPartitionService`	`getPartitionService()` Gets the IPartitionService.
`Operation[]`	`getPostJoinOperations()` Collects all post-join operations from `PostJoinAwareService`s.
`Operation[]`	`getPreJoinOperations()`
`HazelcastProperties`	`getProperties()` Returns the HazelcastProperties.
`InternalProxyService`	`getProxyService()` Gets the ProxyService.
`QuorumServiceImpl`	`getQuorumService()` Gets the QuorumService.
`SerializationService`	`getSerializationService()` Gets the SerializationService.
`<T> T`	`getService(String serviceName)` Gets the service with the given name.
`Collection<ServiceInfo>`	`getServiceInfos(Class serviceClass)`
`ServiceManager`	`getServiceManager()`
`<S> Collection<S>`	`getServices(Class<S> serviceClass)` Returns a list of services matching provides service class/interface.
`<T extends SharedService> T`	`getSharedService(String serviceName)` Gets the `SharedService` for the given serviceName.
`SplitBrainMergePolicyProvider`	`getSplitBrainMergePolicyProvider()` Returns the `SplitBrainMergePolicyProvider` for this instance.
`Address`	`getThisAddress()` Get the address of this member.
`TransactionManagerService`	`getTransactionManagerService()` Gets the TransactionManagerService.
`MemberVersion`	`getVersion()` Returns the codebase version of the node.
`WanReplicationService`	`getWanReplicationService()` Gets the WanReplicationService.
`boolean`	`isActive()` Checks if the HazelcastInstance that this `NodeEngine` belongs to is still active.
`boolean`	`isRunning()` Indicates that node is not shutting down or it has not already shut down
`void`	`onClientDisconnected(String clientUuid)`
`void`	`onMemberLeft(MemberImpl member)`
`void`	`onPartitionMigrate(MigrationInfo migrationInfo)`
`void`	`reset()`
`void`	`shutdown(boolean terminate)`
`void`	`start()`
`Data`	`toData(Object object)` Serializes an object to a `Data`.
`<T> T`	`toObject(Object object)` Deserializes an object.
`<T> T`	`toObject(Object object, Class klazz)` Deserializes an object.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - NodeEngineImpl
```
public NodeEngineImpl(Node node)
```
- Method Detail
  - getLoggingService
```
public LoggingService getLoggingService()
```
  - getMetricsRegistry
```
public MetricsRegistry getMetricsRegistry()
```
  - start
```
public void start()
```
  - getPacketDispatcher
```
public Consumer<Packet> getPacketDispatcher()
```
  - getDiagnostics
```
public Diagnostics getDiagnostics()
```
  - getConfigurationService
```
public ClusterWideConfigurationService getConfigurationService()
```
  - getServiceManager
```
public ServiceManager getServiceManager()
```
  - getThisAddress
```
public Address getThisAddress()
```
    Description copied from interface: NodeEngine
    
    Get the address of this member.
    The returned value will never change and will never be null.
    
    Specified by:
    
    getThisAddress in interface NodeEngine
    
    Returns:
    
    the address of this member
  - getMasterAddress
```
public Address getMasterAddress()
```
    Description copied from interface: NodeEngine
    
    Gets the address of the master member.
    This value can be null if no master is elected yet.
    The value can change over time.
    
    Specified by:
    
    getMasterAddress in interface NodeEngine
    
    Returns:
    
    the address of the master member
  - getLocalMember
```
public MemberImpl getLocalMember()
```
    Description copied from interface: NodeEngine
    
    Returns the local member.
    The returned value will never be null but it may change when local lite member is promoted to a data member or when this member merges to a new cluster after split-brain detected. Returned value should not be cached but instead this method should be called each time when local member is needed.
    
    Specified by:
    
    getLocalMember in interface NodeEngine
    
    Returns:
    
    the local member
  - getConfig
```
public Config getConfig()
```
    Description copied from interface: NodeEngine
    
    Returns the Config that was used to create the HazelcastInstance.
    The returned value will never change and will never be null.
    
    Specified by:
    
    getConfig in interface NodeEngine
    
    Returns:
    
    the config
  - getConfigClassLoader
```
public ClassLoader getConfigClassLoader()
```
    Description copied from interface: NodeEngine
    
    Returns the Config ClassLoader. This class loader will be used for instantiation of all classes defined by the configuration (e.g. listeners, policies, stores, partitioning strategies, quorum functions, ...).
    TODO: add more documentation what the purpose is of the config classloader
    
    Specified by:
    
    getConfigClassLoader in interface NodeEngine
    
    Returns:
    
    the config ClassLoader.
  - getEventService
```
public InternalEventService getEventService()
```
    Description copied from interface: NodeEngine
    
    Gets the EventService.
    
    Specified by:
    
    getEventService in interface NodeEngine
    
    Returns:
    
    the EventService
  - getSerializationService
```
public SerializationService getSerializationService()
```
    Description copied from interface: NodeEngine
    
    Gets the SerializationService.
    
    Specified by:
    
    getSerializationService in interface NodeEngine
    
    Returns:
    
    the SerializationService
  - getOperationService
```
public InternalOperationService getOperationService()
```
    Description copied from interface: NodeEngine
    
    Gets the OperationService.
    
    Specified by:
    
    getOperationService in interface NodeEngine
    
    Returns:
    
    the OperationService
  - getExecutionService
```
public InternalExecutionService getExecutionService()
```
    Description copied from interface: NodeEngine
    
    Gets the ExecutionService.
    
    Specified by:
    
    getExecutionService in interface NodeEngine
    
    Returns:
    
    the ExecutionService
  - getPartitionService
```
public InternalPartitionService getPartitionService()
```
    Description copied from interface: NodeEngine
    
    Gets the IPartitionService.
    
    Specified by:
    
    getPartitionService in interface NodeEngine
    
    Returns:
    
    the IPartitionService
  - getClusterService
```
public ClusterService getClusterService()
```
    Description copied from interface: NodeEngine
    
    Gets the ClusterService.
    
    Specified by:
    
    getClusterService in interface NodeEngine
    
    Returns:
    
    the ClusterService
  - getManagementCenterService
```
public ManagementCenterService getManagementCenterService()
```
  - getProxyService
```
public InternalProxyService getProxyService()
```
    Description copied from interface: NodeEngine
    
    Gets the ProxyService.
    
    Specified by:
    
    getProxyService in interface NodeEngine
    
    Returns:
    
    the ProxyService
  - getOperationParker
```
public OperationParker getOperationParker()
```
  - getWanReplicationService
```
public WanReplicationService getWanReplicationService()
```
    Description copied from interface: NodeEngine
    
    Gets the WanReplicationService.
    
    Specified by:
    
    getWanReplicationService in interface NodeEngine
    
    Returns:
    
    the WanReplicationService
  - getQuorumService
```
public QuorumServiceImpl getQuorumService()
```
    Description copied from interface: NodeEngine
    
    Gets the QuorumService.
    
    Specified by:
    
    getQuorumService in interface NodeEngine
    
    Returns:
    
    the QuorumService
  - getTransactionManagerService
```
public TransactionManagerService getTransactionManagerService()
```
    Description copied from interface: NodeEngine
    
    Gets the TransactionManagerService.
    
    Specified by:
    
    getTransactionManagerService in interface NodeEngine
    
    Returns:
    
    the TransactionManagerService
  - toData
```
public Data toData(Object object)
```
    Description copied from interface: NodeEngine
    
    Serializes an object to a Data.
    This method can safely be called with a Data instance. In that case, that instance is returned.
    If this method is called with null, null is returned.
    
    Specified by:
    
    toData in interface NodeEngine
    
    Parameters:
    
    object - the object to serialize
    
    Returns:
    
    the serialized object
  - toObject
```
public <T> T toObject(Object object)
```
    Description copied from interface: NodeEngine
    
    Deserializes an object.
    This method can safely be called on an object that is already deserialized. In that case, that instance is returned.
    If this method is called with null, null is returned.
    
    Specified by:
    
    toObject in interface NodeEngine
    
    Parameters:
    
    object - the object to deserialize
    
    Returns:
    
    the deserialized object
  - toObject
```
public <T> T toObject(Object object,
                      Class klazz)
```
    Description copied from interface: NodeEngine
    
    Deserializes an object.
    This method can safely be called on an object that is already deserialized. In that case, that instance is returned.
    If this method is called with null, null is returned.
    
    Specified by:
    
    toObject in interface NodeEngine
    
    Parameters:
    
    object - the object to deserialize
    
    klazz - The class to instantiate when deserializing the object
    
    Returns:
    
    the deserialized object
  - isActive
```
public boolean isActive()
```
    Description copied from interface: NodeEngine
    
    Checks if the HazelcastInstance that this NodeEngine belongs to is still active.
    A HazelcastInstance is not active when it is shutting down or already shut down. Also see NodeEngine.isRunning().
    
    Specified by:
    
    isActive in interface NodeEngine
    
    Returns:
    
    true if active, false otherwise
  - isRunning
```
public boolean isRunning()
```
    Description copied from interface: NodeEngine
    
    Indicates that node is not shutting down or it has not already shut down
    
    Specified by:
    
    isRunning in interface NodeEngine
    
    Returns:
    
    true if node is not shutting down or it has not already shut down, false otherwise
  - getHazelcastInstance
```
public HazelcastInstance getHazelcastInstance()
```
    Description copied from interface: NodeEngine
    
    Returns the HazelcastInstance that this NodeEngine belongs to.
    
    Specified by:
    
    getHazelcastInstance in interface NodeEngine
    
    Returns:
    
    the HazelcastInstance
  - getLogger
```
public ILogger getLogger(String name)
```
    Description copied from interface: NodeEngine
    
    Gets the logger for a given name.
    It is best to get an ILogger through this method instead of calling Logger.getLogger(String).
    
    Specified by:
    
    getLogger in interface NodeEngine
    
    Parameters:
    
    name - the name of the logger
    
    Returns:
    
    the ILogger
    
    See Also:
    
    NodeEngine.getLogger(String)
  - getLogger
```
public ILogger getLogger(Class clazz)
```
    Description copied from interface: NodeEngine
    
    Gets the logger for a given class.
    It is best to get an ILogger through this method instead of calling Logger.getLogger(Class).
    
    Specified by:
    
    getLogger in interface NodeEngine
    
    Parameters:
    
    clazz - the class of the logger
    
    Returns:
    
    the ILogger
    
    See Also:
    
    NodeEngine.getLogger(Class)
  - getProperties
```
public HazelcastProperties getProperties()
```
    Description copied from interface: NodeEngine
    
    Returns the HazelcastProperties.
    The returned value will never change and will never be null.
    
    Specified by:
    
    getProperties in interface NodeEngine
    
    Returns:
    
    the HazelcastProperties
  - getService
```
public <T> T getService(String serviceName)
```
    Description copied from interface: NodeEngine
    
    Gets the service with the given name.
    
    Specified by:
    
    getService in interface NodeEngine
    
    Type Parameters:
    
    T - the type of the service
    
    Parameters:
    
    serviceName - the name of the service
    
    Returns:
    
    the found service, or HazelcastException in case of failure (null will never be returned)
  - getSharedService
```
public <T extends SharedService> T getSharedService(String serviceName)
```
    Description copied from interface: NodeEngine
    
    Gets the SharedService for the given serviceName.
    
    Specified by:
    
    getSharedService in interface NodeEngine
    
    Type Parameters:
    
    T - the type of the service
    
    Parameters:
    
    serviceName - the name of the shared service to get
    
    Returns:
    
    the found service, or null if the service was not found
  - getVersion
```
public MemberVersion getVersion()
```
    Description copied from interface: NodeEngine
    
    Returns the codebase version of the node. For example, when running on hazelcast-3.8.jar, this would resolve to Version.of(3,8,0). A node's codebase version may be different than cluster version.
    
    Specified by:
    
    getVersion in interface NodeEngine
    
    Returns:
    
    codebase version of the node
    
    See Also:
    
    Cluster.getClusterVersion()
  - getSplitBrainMergePolicyProvider
```
public SplitBrainMergePolicyProvider getSplitBrainMergePolicyProvider()
```
    Description copied from interface: NodeEngine
    
    Returns the SplitBrainMergePolicyProvider for this instance.
    
    Specified by:
    
    getSplitBrainMergePolicyProvider in interface NodeEngine
    
    Returns:
    
    the SplitBrainMergePolicyProvider
  - getServices
```
public <S> Collection<S> getServices(Class<S> serviceClass)
```
    Description copied from interface: NodeEngine
    
    Returns a list of services matching provides service class/interface.
    Note: CoreServices will be placed at the beginning of the list.
    
    Specified by:
    
    getServices in interface NodeEngine
  - getServiceInfos
```
public Collection<ServiceInfo> getServiceInfos(Class serviceClass)
```
  - getNode
```
public Node getNode()
```
  - onMemberLeft
```
public void onMemberLeft(MemberImpl member)
```
  - onClientDisconnected
```
public void onClientDisconnected(String clientUuid)
```
  - onPartitionMigrate
```
public void onPartitionMigrate(MigrationInfo migrationInfo)
```
  - getPostJoinOperations
```
public Operation[] getPostJoinOperations()
```
    Collects all post-join operations from PostJoinAwareServices.
    Post join operations should return response, at least a null response.
    Note: Post join operations must be lock free, meaning no locks at all: no partition locks, no key-based locks, no service level locks, no database interaction! The Operation.getPartitionId() method should return a negative value. This means that the operations should not implement PartitionAwareOperation.
    
    Returns:
    
    the operations to be executed at the end of a finalized join
  - getPreJoinOperations
```
public Operation[] getPreJoinOperations()
```
  - reset
```
public void reset()
```
  - shutdown
```
public void shutdown(boolean terminate)
```

Class NodeEngineImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

NodeEngineImpl

Method Detail

getLoggingService

getMetricsRegistry

start

getPacketDispatcher

getDiagnostics

getConfigurationService

getServiceManager

getThisAddress

getMasterAddress

getLocalMember

getConfig

getConfigClassLoader

getEventService

getSerializationService

getOperationService

getExecutionService

getPartitionService

getClusterService

getManagementCenterService

getProxyService

getOperationParker

getWanReplicationService

getQuorumService

getTransactionManagerService

toData

toObject

toObject

isActive

isRunning

getHazelcastInstance

getLogger

getLogger

getProperties

getService

getSharedService

getVersion

getSplitBrainMergePolicyProvider

getServices

getServiceInfos

getNode

onMemberLeft

onClientDisconnected

onPartitionMigrate

getPostJoinOperations

getPreJoinOperations

reset

shutdown