public class DefaultClientExtension extends Object implements ClientExtension
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected static ILogger |
LOGGER |
Constructor and Description |
---|
DefaultClientExtension() |
Modifier and Type | Method and Description |
---|---|
void |
afterStart(HazelcastClientInstanceImpl client)
Called after node is started
|
void |
beforeStart(HazelcastClientInstanceImpl client)
Called before client is started
|
ChannelInitializer |
createChannelInitializer() |
ChannelInitializer |
createChannelInitializer(SSLConfig sslConfig,
SocketOptions socketOptions) |
NearCacheManager |
createNearCacheManager()
Creates a
NearCacheManager instance to be used by this client. |
InternalSerializationService |
createSerializationService(byte version)
Creates a
InternalSerializationService instance to be used by this client. |
<T> ClientProxyFactory |
createServiceProxyFactory(Class<T> service)
Creates a
ClientProxyFactory for the supplied service class. |
SocketInterceptor |
createSocketInterceptor()
Creates a
SocketInterceptor to be used by this client if available,
otherwise returns null |
SocketInterceptor |
createSocketInterceptor(SocketInterceptorConfig socketInterceptorConfig)
Create socket interceptor according to given config
|
MemoryStats |
getMemoryStats()
Returns MemoryStats of for the JVM and current HazelcastInstance.
|
protected PartitioningStrategy |
getPartitioningStrategy(ClassLoader configClassLoader) |
protected static final ILogger LOGGER
protected volatile HazelcastClientInstanceImpl client
public void beforeStart(HazelcastClientInstanceImpl client)
ClientExtension
beforeStart
in interface ClientExtension
public void afterStart(HazelcastClientInstanceImpl client)
ClientExtension
afterStart
in interface ClientExtension
public InternalSerializationService createSerializationService(byte version)
ClientExtension
InternalSerializationService
instance to be used by this client.createSerializationService
in interface ClientExtension
version
- serialization version to be created. Values less than 1 will be ignored and max supported version
will be usedInternalSerializationService
instanceprotected PartitioningStrategy getPartitioningStrategy(ClassLoader configClassLoader) throws Exception
Exception
public SocketInterceptor createSocketInterceptor()
ClientExtension
SocketInterceptor
to be used by this client if available,
otherwise returns null
createSocketInterceptor
in interface ClientExtension
SocketInterceptor
instance if available,
+ otherwise null
public SocketInterceptor createSocketInterceptor(SocketInterceptorConfig socketInterceptorConfig)
ClientExtension
createSocketInterceptor
in interface ClientExtension
socketInterceptorConfig
- config for socket interceptorpublic ChannelInitializer createChannelInitializer()
createChannelInitializer
in interface ClientExtension
public ChannelInitializer createChannelInitializer(SSLConfig sslConfig, SocketOptions socketOptions)
createChannelInitializer
in interface ClientExtension
sslConfig
- ssl config for channel initializersocketOptions
- socket options for channel initializerpublic <T> ClientProxyFactory createServiceProxyFactory(Class<T> service)
ClientExtension
ClientProxyFactory
for the supplied service class. Currently only the MapService
is supported.createServiceProxyFactory
in interface ClientExtension
service
- service for the proxy to create.ClientProxyFactory
for the service.public MemoryStats getMemoryStats()
ClientExtension
getMemoryStats
in interface ClientExtension
public NearCacheManager createNearCacheManager()
ClientExtension
NearCacheManager
instance to be used by this client.createNearCacheManager
in interface ClientExtension
NearCacheManager
instanceCopyright © 2020 Hazelcast, Inc.. All Rights Reserved.