public abstract class SessionAwareProxy extends Object
Modifier and Type | Field and Description |
---|---|
protected RaftGroupId |
groupId |
Modifier | Constructor and Description |
---|---|
protected |
SessionAwareProxy(AbstractProxySessionManager sessionManager,
RaftGroupId groupId) |
Modifier and Type | Method and Description |
---|---|
protected long |
acquireSession()
Increments acquire count of the session.
|
protected long |
acquireSession(int count)
Increments acquire count of the session.
|
RaftGroupId |
getGroupId() |
protected Long |
getOrCreateUniqueThreadId(RaftGroupId groupId) |
protected long |
getSession()
Returns id of the session opened for the given Raft group.
|
protected void |
invalidateSession(long sessionId)
Invalidates the given session.
|
protected void |
releaseSession(long sessionId)
Decrements acquire count of the session.
|
protected void |
releaseSession(long sessionId,
int count)
Decrements acquire count of the session.
|
protected final RaftGroupId groupId
protected SessionAwareProxy(AbstractProxySessionManager sessionManager, RaftGroupId groupId)
public final RaftGroupId getGroupId()
protected final Long getOrCreateUniqueThreadId(RaftGroupId groupId)
protected final long acquireSession()
protected final long acquireSession(int count)
protected final void releaseSession(long sessionId)
protected final void releaseSession(long sessionId, int count)
protected final void invalidateSession(long sessionId)
protected final long getSession()
AbstractProxySessionManager.NO_SESSION_ID
if no session exists.Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.