com.hazelcast.spi.impl
Class NodeEngineImpl

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

All Implemented Interfaces:

NodeEngine

public class NodeEngineImpl
extends Object
implements NodeEngine

Constructor Summary

NodeEngineImpl(Node node)

Method Summary

ClusterService	getClusterService()
long	getClusterTime()
Config	getConfig()
ClassLoader	getConfigClassLoader()
EventService	getEventService()
ExecutionService	getExecutionService()
GroupProperties	getGroupProperties()
HazelcastInstance	getHazelcastInstance()
MemberImpl	getLocalMember()
ILogger	getLogger(Class clazz)
ILogger	getLogger(String name)
ManagementCenterService	getManagementCenterService()
Address	getMasterAddress()
Node	getNode()
Storage<DataRef>	getOffHeapStorage()
OperationService	getOperationService()
InternalPartitionService	getPartitionService()
PortableContext	getPortableContext()
Operation[]	getPostJoinOperations() Post join operations must be lock free; means no locks at all; no partition locks, no key-based locks, no service level locks! Post join operations should return response, at least a null response.
ProxyService	getProxyService()
SerializationService	getSerializationService()
<T> T	getService(String serviceName)
Collection<ServiceInfo>	getServiceInfos(Class serviceClass)
<S> Collection<S>	getServices(Class<S> serviceClass) Returns a list of services matching provides service class/interface.
<T extends SharedService> T	getSharedService(String serviceName)
Address	getThisAddress()
TransactionManagerService	getTransactionManagerService()
WaitNotifyService	getWaitNotifyService()
WanReplicationService	getWanReplicationService()
void	handlePacket(Packet packet)
boolean	isActive()
void	onClientDisconnected(String clientUuid)
void	onMemberLeft(MemberImpl member)
void	onPartitionMigrate(MigrationInfo migrationInfo)
void	reset()
boolean	send(Packet packet, Address target) Retries sending packet maximum 5 times until connection to target becomes available.
boolean	send(Packet packet, Connection connection)
void	shutdown(boolean terminate)
void	start()
Data	toData(Object object)
Object	toObject(Object 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

start

@PrivateApi
public void start()

getThisAddress

public Address getThisAddress()

Specified by:

getThisAddress in interface NodeEngine

getMasterAddress

public Address getMasterAddress()

Specified by:

getMasterAddress in interface NodeEngine

getLocalMember

public MemberImpl getLocalMember()

Specified by:

getLocalMember in interface NodeEngine

getConfig

public Config getConfig()

Specified by:

getConfig in interface NodeEngine

getConfigClassLoader

public ClassLoader getConfigClassLoader()

Specified by:

getConfigClassLoader in interface NodeEngine

getEventService

public EventService getEventService()

Specified by:

getEventService in interface NodeEngine

getSerializationService

public SerializationService getSerializationService()

Specified by:

getSerializationService in interface NodeEngine

getPortableContext

public PortableContext getPortableContext()

getOperationService

public OperationService getOperationService()

Specified by:

getOperationService in interface NodeEngine

getExecutionService

public ExecutionService getExecutionService()

Specified by:

getExecutionService in interface NodeEngine

getPartitionService

public InternalPartitionService getPartitionService()

Specified by:

getPartitionService in interface NodeEngine

getClusterService

public ClusterService getClusterService()

Specified by:

getClusterService in interface NodeEngine

getManagementCenterService

public ManagementCenterService getManagementCenterService()

getProxyService

public ProxyService getProxyService()

Specified by:

getProxyService in interface NodeEngine

getWaitNotifyService

public WaitNotifyService getWaitNotifyService()

Specified by:

getWaitNotifyService in interface NodeEngine

getWanReplicationService

public WanReplicationService getWanReplicationService()

Specified by:

getWanReplicationService in interface NodeEngine

getTransactionManagerService

public TransactionManagerService getTransactionManagerService()

Specified by:

getTransactionManagerService in interface NodeEngine

toData

public Data toData(Object object)

Specified by:

toData in interface NodeEngine

toObject

public Object toObject(Object object)

Specified by:

toObject in interface NodeEngine

isActive

public boolean isActive()

Specified by:

isActive in interface NodeEngine

getHazelcastInstance

public HazelcastInstance getHazelcastInstance()

Specified by:

getHazelcastInstance in interface NodeEngine

send

public boolean send(Packet packet,
                    Connection connection)

send

public boolean send(Packet packet,
                    Address target)

Retries sending packet maximum 5 times until connection to target becomes available.

getLogger

public ILogger getLogger(String name)

Specified by:

getLogger in interface NodeEngine

getLogger

public ILogger getLogger(Class clazz)

Specified by:

getLogger in interface NodeEngine

getGroupProperties

public GroupProperties getGroupProperties()

Specified by:

getGroupProperties in interface NodeEngine

handlePacket

@PrivateApi
public void handlePacket(Packet packet)

getService

@PrivateApi
public <T> T getService(String serviceName)

getSharedService

public <T extends SharedService> T getSharedService(String serviceName)

Specified by:

getSharedService in interface NodeEngine

getServices

@PrivateApi
public <S> Collection<S> getServices(Class<S> serviceClass)

Returns a list of services matching provides service class/interface.

CoreServices will be placed at the beginning of the list.

getServiceInfos

@PrivateApi
public Collection<ServiceInfo> getServiceInfos(Class serviceClass)

getNode

@PrivateApi
public Node getNode()

onMemberLeft

@PrivateApi
public void onMemberLeft(MemberImpl member)

onClientDisconnected

@PrivateApi
public void onClientDisconnected(String clientUuid)

onPartitionMigrate

@PrivateApi
public void onPartitionMigrate(MigrationInfo migrationInfo)

getPostJoinOperations

@PrivateApi
public Operation[] getPostJoinOperations()

Post join operations must be lock free; means no locks at all; no partition locks, no key-based locks, no service level locks!

Post join operations should return response, at least a null response.

getClusterTime

public long getClusterTime()

getOffHeapStorage

public Storage<DataRef> getOffHeapStorage()

Specified by:

getOffHeapStorage in interface NodeEngine

reset

@PrivateApi
public void reset()

shutdown

@PrivateApi
public void shutdown(boolean terminate)