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) 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.

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

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

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)

Description copied from class: AbstractProxySessionManager

Generates a cluster-wide unique thread id for the caller

Specified by:

generateThreadId in class AbstractProxySessionManager

requestNewSession

protected SessionResponse requestNewSession(RaftGroupId groupId)

Description copied from class: AbstractProxySessionManager

Creates a new session on the Raft group

Specified by:

requestNewSession in class AbstractProxySessionManager

scheduleWithRepetition

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

Description copied from class: AbstractProxySessionManager

Schedules the given task for repeating execution

Specified by:

scheduleWithRepetition in class AbstractProxySessionManager

heartbeat

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

Description copied from class: AbstractProxySessionManager

Commits a heartbeat for the session on the Raft group

Specified by:

heartbeat in class AbstractProxySessionManager

closeSession

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

Description copied from class: AbstractProxySessionManager

Closes the given session on the Raft group

Specified by:

closeSession in class AbstractProxySessionManager

shutdown

public Map<RaftGroupId,ICompletableFuture<Object>> shutdown()

Description copied from class: AbstractProxySessionManager

Invokes a shutdown call on server to close all existing sessions.

Overrides:

shutdown in class AbstractProxySessionManager