public class NoOpClientEngine extends Object implements ClientEngine
Constructor and Description |
---|
NoOpClientEngine() |
Modifier and Type | Method and Description |
---|---|
void |
accept(ClientMessage clientMessage) |
void |
addBackupListener(UUID clientUUID,
Consumer<Long> backupListener) |
void |
applySelector(ClientSelector selector)
Only Clients that can pass through filter are allowed to connect to cluster.
|
boolean |
bind(ClientEndpoint endpoint)
Registers client endpoint to endpointManager.
|
Address |
clientAddressOf(Address clientAddress)
Locates the client address of the given member address.
|
boolean |
deregisterBackupListener(UUID clientUUID) |
void |
dispatchBackupEvent(UUID clientUUID,
long clientCorrelationId) |
int |
getClientEndpointCount() |
ClientExceptions |
getClientExceptions() |
Collection<Client> |
getClients() |
Map<UUID,String> |
getClientStatistics()
The statistics is a String that is composed of key=value pairs separated by ',' .
|
ClusterService |
getClusterService() |
Map<ClientType,Integer> |
getConnectedClientStats()
Returns Map which contains number of connected clients to the cluster.
|
ClientEndpointManager |
getEndpointManager() |
EventService |
getEventService() |
ILogger |
getLogger(Class clazz) |
ClientPartitionListenerService |
getPartitionListenerService() |
IPartitionService |
getPartitionService() |
ProxyService |
getProxyService() |
SecurityContext |
getSecurityContext() |
Address |
getThisAddress() |
TransactionManagerService |
getTransactionManagerService() |
boolean |
isClientAllowed(Client client) |
Address |
memberAddressOf(Address clientAddress)
Locates the cluster member that has the provided client address and returns its member address,
to be used for intra-cluster communication.
|
void |
onClientAcquiredResource(UUID uuid)
Notify client engine that a client with given uuid required a resource (lock) on this member
|
public boolean bind(ClientEndpoint endpoint)
ClientEngine
ClientEngine.applySelector(com.hazelcast.client.impl.ClientSelector)
bind
in interface ClientEngine
endpoint
- to be registered to client enginepublic Collection<Client> getClients()
getClients
in interface ClientEngine
public int getClientEndpointCount()
getClientEndpointCount
in interface ClientEngine
public IPartitionService getPartitionService()
getPartitionService
in interface ClientEngine
public ClusterService getClusterService()
getClusterService
in interface ClientEngine
public EventService getEventService()
getEventService
in interface ClientEngine
public ProxyService getProxyService()
getProxyService
in interface ClientEngine
public ILogger getLogger(Class clazz)
getLogger
in interface ClientEngine
public Address getThisAddress()
getThisAddress
in interface ClientEngine
Node.getThisAddress()
public ClientEndpointManager getEndpointManager()
getEndpointManager
in interface ClientEngine
public ClientExceptions getClientExceptions()
getClientExceptions
in interface ClientEngine
public SecurityContext getSecurityContext()
getSecurityContext
in interface ClientEngine
public TransactionManagerService getTransactionManagerService()
getTransactionManagerService
in interface ClientEngine
public ClientPartitionListenerService getPartitionListenerService()
getPartitionListenerService
in interface ClientEngine
public Map<ClientType,Integer> getConnectedClientStats()
ClientEngine
getConnectedClientStats
in interface ClientEngine
Map<ClientType, Integer>
.public Map<UUID,String> getClientStatistics()
ClientEngine
<example.fastmap>
and ICache Named
<StatTestCacheName>
and assuming that the Near Cache is configured):
clientType clusterConnectionTimestamp credentials.principal clientAddress clientName enterprise lastStatisticsCollectionTime nearcache.<example\.fastmap>.creationTime nearcache.<example\.fastmap>.evictions nearcache.<example\.fastmap>.expirations nearcache.<example\.fastmap>.hits nearcache.<example\.fastmap>.lastPersistenceDuration nearcache.<example\.fastmap>.lastPersistenceFailure nearcache.<example\.fastmap>.lastPersistenceKeyCount nearcache.<example\.fastmap>.lastPersistenceTime nearcache.<example\.fastmap>.lastPersistenceWrittenBytes nearcache.<example\.fastmap>.misses nearcache.<example\.fastmap>.ownedEntryCount nearcache.<example\.fastmap>.ownedEntryMemoryCost nearcache.hz/<StatTestCacheName>.creationTime nearcache.hz/<StatTestCacheName>.evictions nearcache.hz/<StatTestCacheName>.expirations nearcache.hz/<StatTestCacheName>.hits nearcache.hz/<StatTestCacheName>.lastPersistenceDuration nearcache.hz/<StatTestCacheName>.lastPersistenceFailure nearcache.hz/<StatTestCacheName>.lastPersistenceKeyCount nearcache.hz/<StatTestCacheName>.lastPersistenceTime nearcache.hz/<StatTestCacheName>.lastPersistenceWrittenBytes nearcache.hz/<StatTestCacheName>.misses nearcache.hz/<StatTestCacheName>.ownedEntryCount nearcache.hz/<StatTestCacheName>.ownedEntryMemoryCost os.committedVirtualMemorySize os.freePhysicalMemorySize os.freeSwapSpaceSize os.maxFileDescriptorCount os.openFileDescriptorCount os.processCpuTime os.systemLoadAverage os.totalPhysicalMemorySize os.totalSwapSpaceSize runtime.availableProcessors runtime.freeMemory runtime.maxMemory runtime.totalMemory runtime.uptime runtime.usedMemory userExecutor.queueSizeNot: Please observe that the name for the ICache appears to be the hazelcast instance name "hz" followed by "/" and followed by the cache name provided which is StatTestCacheName.
getClientStatistics
in interface ClientEngine
public boolean isClientAllowed(Client client)
isClientAllowed
in interface ClientEngine
client
- to check if allowed through current ClientSelectorpublic void applySelector(ClientSelector selector)
ClientEngine
applySelector
in interface ClientEngine
selector
- to select a client or group of clients to act uponpublic void accept(ClientMessage clientMessage)
accept
in interface Consumer<ClientMessage>
public Address memberAddressOf(Address clientAddress)
ClientEngine
TargetNotMemberException
when no member with the
provided client address can be located.memberAddressOf
in interface ClientEngine
clientAddress
- the client address of the memberpublic Address clientAddressOf(Address clientAddress)
ClientEngine
ClientEngine.memberAddressOf(Address)
.clientAddressOf
in interface ClientEngine
clientAddress
- the member address of the memberpublic void onClientAcquiredResource(UUID uuid)
ClientEngine
onClientAcquiredResource
in interface ClientEngine
uuid
- client uuidpublic void addBackupListener(UUID clientUUID, Consumer<Long> backupListener)
addBackupListener
in interface ClientEngine
public void dispatchBackupEvent(UUID clientUUID, long clientCorrelationId)
dispatchBackupEvent
in interface ClientEngine
public boolean deregisterBackupListener(UUID clientUUID)
deregisterBackupListener
in interface ClientEngine
Copyright © 2019 Hazelcast, Inc.. All rights reserved.