public class ClientEngineImpl extends Object implements ClientEngine, com.hazelcast.nio.ConnectionListener, CoreService, ManagedService, MembershipAwareService, EventPublishingService<ClientEndpoint,ClientListener>
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
ClientEngineImpl(com.hazelcast.instance.Node node) |
Modifier and Type | Method and Description |
---|---|
void |
connectionAdded(com.hazelcast.nio.Connection connection) |
void |
connectionRemoved(com.hazelcast.nio.Connection connection) |
void |
dispatchEvent(ClientEndpoint event,
ClientListener listener) |
int |
getClientEndpointCount() |
ClientService |
getClientService() |
ClusterService |
getClusterService() |
Config |
getConfig() |
int |
getDeadConnectionCount() |
Collection<Client> |
getEndpoints() |
EventService |
getEventService() |
com.hazelcast.instance.MemberImpl |
getLocalMember() |
com.hazelcast.logging.ILogger |
getLogger(Class clazz) |
com.hazelcast.logging.ILogger |
getLogger(String className) |
com.hazelcast.nio.Address |
getMasterAddress() |
com.hazelcast.partition.InternalPartitionService |
getPartitionService() |
ProxyService |
getProxyService() |
SecurityContext |
getSecurityContext() |
SerializationService |
getSerializationService() |
com.hazelcast.nio.Address |
getThisAddress() |
TransactionManagerService |
getTransactionManagerService() |
void |
handlePacket(com.hazelcast.nio.ClientPacket packet) |
void |
init(NodeEngine nodeEngine,
Properties properties) |
void |
memberAdded(MembershipServiceEvent event)
Invoked when a new member is added to the cluster.
|
void |
memberRemoved(MembershipServiceEvent event)
Invoked when an existing member leaves the cluster.
|
void |
reset()
reset service, back to initial state
|
void |
sendResponse(ClientEndpoint endpoint,
Object response) |
void |
shutdown()
shutdown service
|
Data |
toData(Object obj) |
Object |
toObject(Data data) |
public static final String SERVICE_NAME
public int getClientEndpointCount()
getClientEndpointCount
in interface ClientEngine
public int getDeadConnectionCount()
getDeadConnectionCount
in interface ClientEngine
public void handlePacket(com.hazelcast.nio.ClientPacket packet)
public Object toObject(Data data)
toObject
in interface ClientEngine
public Data toData(Object obj)
toData
in interface ClientEngine
public com.hazelcast.partition.InternalPartitionService getPartitionService()
getPartitionService
in interface ClientEngine
public ClusterService getClusterService()
getClusterService
in interface ClientEngine
public SerializationService getSerializationService()
getSerializationService
in interface ClientEngine
public EventService getEventService()
getEventService
in interface ClientEngine
public ProxyService getProxyService()
getProxyService
in interface ClientEngine
public void sendResponse(ClientEndpoint endpoint, Object response)
sendResponse
in interface ClientEngine
public TransactionManagerService getTransactionManagerService()
getTransactionManagerService
in interface ClientEngine
public com.hazelcast.nio.Address getMasterAddress()
getMasterAddress
in interface ClientEngine
public com.hazelcast.nio.Address getThisAddress()
getThisAddress
in interface ClientEngine
public com.hazelcast.instance.MemberImpl getLocalMember()
getLocalMember
in interface ClientEngine
public Config getConfig()
getConfig
in interface ClientEngine
public com.hazelcast.logging.ILogger getLogger(Class clazz)
getLogger
in interface ClientEngine
public com.hazelcast.logging.ILogger getLogger(String className)
getLogger
in interface ClientEngine
public void connectionAdded(com.hazelcast.nio.Connection connection)
connectionAdded
in interface com.hazelcast.nio.ConnectionListener
public void connectionRemoved(com.hazelcast.nio.Connection connection)
connectionRemoved
in interface com.hazelcast.nio.ConnectionListener
public SecurityContext getSecurityContext()
getSecurityContext
in interface ClientEngine
public void dispatchEvent(ClientEndpoint event, ClientListener listener)
dispatchEvent
in interface EventPublishingService<ClientEndpoint,ClientListener>
public void memberAdded(MembershipServiceEvent event)
MembershipAwareService
memberAdded
in interface MembershipAwareService
public void memberRemoved(MembershipServiceEvent event)
MembershipAwareService
memberRemoved
in interface MembershipAwareService
public ClientService getClientService()
public Collection<Client> getEndpoints()
public void init(NodeEngine nodeEngine, Properties properties)
init
in interface ManagedService
public void reset()
ManagedService
reset
in interface ManagedService
public void shutdown()
ManagedService
shutdown
in interface ManagedService
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.