com.hazelcast.spi.impl
Class NodeEngineImpl

java.lang.Object
  extended by 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)


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.