public interface ClientEngine extends Consumer<ClientMessage>
void bind(ClientEndpoint endpoint)
Collection<Client> getClients()
int getClientEndpointCount()
IPartitionService getPartitionService()
ClusterService getClusterService()
EventService getEventService()
ProxyService getProxyService()
Address getThisAddress()
Node.getThisAddress()
String getThisUuid()
ClientEndpointManager getEndpointManager()
ClientExceptions getClientExceptions()
SecurityContext getSecurityContext()
TransactionManagerService getTransactionManagerService()
ClientPartitionListenerService getPartitionListenerService()
Map<ClientType,Integer> getConnectedClientStats()
Map<String,String> getClientStatistics()
boolean isClientAllowed(Client client)
client
- to check if allowed through current ClientSelectorvoid applySelector(ClientSelector selector)
selector
- to select a client or group of clients to act uponAddress memberAddressOf(Address clientAddress)
TargetNotMemberException
when no member with the
provided client address can be located.clientAddress
- the client address of the memberAddress clientAddressOf(Address memberAddress)
memberAddressOf(Address)
.memberAddress
- the member address of the memberCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.