public class ClientProxySessionManager extends AbstractProxySessionManager
NO_SESSION_ID
Constructor and Description |
---|
ClientProxySessionManager(HazelcastClientInstanceImpl client) |
Modifier and Type | Method and Description |
---|---|
protected ICompletableFuture<Object> |
closeSession(RaftGroupId groupId,
Long sessionId)
Closes the given session on the Raft group
|
protected long |
generateThreadId(RaftGroupId groupId)
Generates a cluster-wide unique thread id for the caller
|
protected ICompletableFuture<Object> |
heartbeat(RaftGroupId groupId,
long sessionId)
Commits a heartbeat for the session on the Raft group
|
protected SessionResponse |
requestNewSession(RaftGroupId groupId)
Creates a new session on the Raft group
|
protected ScheduledFuture<?> |
scheduleWithRepetition(Runnable task,
long period,
TimeUnit unit)
Schedules the given task for repeating execution
|
Map<RaftGroupId,ICompletableFuture<Object>> |
shutdown()
Invokes a shutdown call on server to close all existing sessions.
|
acquireSession, acquireSession, getOrCreateUniqueThreadId, getSession, getSessionAcquireCount, invalidateSession, releaseSession, releaseSession, resetInternalState
public ClientProxySessionManager(HazelcastClientInstanceImpl client)
protected long generateThreadId(RaftGroupId groupId)
AbstractProxySessionManager
generateThreadId
in class AbstractProxySessionManager
protected SessionResponse requestNewSession(RaftGroupId groupId)
AbstractProxySessionManager
requestNewSession
in class AbstractProxySessionManager
protected ScheduledFuture<?> scheduleWithRepetition(Runnable task, long period, TimeUnit unit)
AbstractProxySessionManager
scheduleWithRepetition
in class AbstractProxySessionManager
protected ICompletableFuture<Object> heartbeat(RaftGroupId groupId, long sessionId)
AbstractProxySessionManager
heartbeat
in class AbstractProxySessionManager
protected ICompletableFuture<Object> closeSession(RaftGroupId groupId, Long sessionId)
AbstractProxySessionManager
closeSession
in class AbstractProxySessionManager
public Map<RaftGroupId,ICompletableFuture<Object>> shutdown()
AbstractProxySessionManager
shutdown
in class AbstractProxySessionManager
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.