com.hazelcast.client.cp.internal.session

Class ClientProxySessionManager

java.lang.Object

com.hazelcast.cp.internal.session.AbstractProxySessionManager

com.hazelcast.client.cp.internal.session.ClientProxySessionManager

public class ClientProxySessionManager
extends AbstractProxySessionManager

Client-side implementation of Raft proxy session manager

Field Summary

Fields inherited from class com.hazelcast.cp.internal.session.AbstractProxySessionManager

NO_SESSION_ID

Constructor Summary

Constructors

Constructor and Description
ClientProxySessionManager(HazelcastClientInstanceImpl client)

Method Summary

Modifier and Type	Method and Description
protected ICompletableFuture<Object>	closeSession(RaftGroupId groupId, Long sessionId)
protected long	generateThreadId(RaftGroupId groupId)
protected ICompletableFuture<Object>	heartbeat(RaftGroupId groupId, long sessionId)
protected SessionResponse	requestNewSession(RaftGroupId groupId)
protected ScheduledFuture<?>	scheduleWithRepetition(Runnable task, long period, TimeUnit unit)
void	shutdownAndAwait()

Methods inherited from class com.hazelcast.cp.internal.session.AbstractProxySessionManager

acquireSession, acquireSession, getOrCreateUniqueThreadId, getSession, getSessionAcquireCount, invalidateSession, releaseSession, releaseSession, resetInternalState, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientProxySessionManager

public ClientProxySessionManager(HazelcastClientInstanceImpl client)

Method Detail

generateThreadId

protected long generateThreadId(RaftGroupId groupId)

Specified by:

generateThreadId in class AbstractProxySessionManager

requestNewSession

protected SessionResponse requestNewSession(RaftGroupId groupId)

Specified by:

requestNewSession in class AbstractProxySessionManager

scheduleWithRepetition

protected ScheduledFuture<?> scheduleWithRepetition(Runnable task,
                                                    long period,
                                                    TimeUnit unit)

Specified by:

scheduleWithRepetition in class AbstractProxySessionManager

heartbeat

protected ICompletableFuture<Object> heartbeat(RaftGroupId groupId,
                                               long sessionId)

Specified by:

heartbeat in class AbstractProxySessionManager

closeSession

protected ICompletableFuture<Object> closeSession(RaftGroupId groupId,
                                                  Long sessionId)

Specified by:

closeSession in class AbstractProxySessionManager

shutdownAndAwait

public void shutdownAndAwait()