private static class SimpleBrokerMessageHandler.SessionInfo
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private MessageChannel |
clientOutboundChannel |
private static long |
HEARTBEAT_MULTIPLIER |
private long |
lastReadTime |
private long |
lastWriteTime |
private long |
readInterval |
private java.lang.String |
sessionId |
private java.security.Principal |
user |
private long |
writeInterval |
Constructor and Description |
---|
SessionInfo(java.lang.String sessionId,
java.security.Principal user,
MessageChannel outboundChannel,
long[] clientHeartbeat,
long[] serverHeartbeat) |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
getClientOutboundChannel() |
long |
getLastReadTime() |
long |
getLastWriteTime() |
long |
getReadInterval() |
java.lang.String |
getSessionId() |
java.security.Principal |
getUser() |
long |
getWriteInterval() |
void |
setLastReadTime(long lastReadTime) |
void |
setLastWriteTime(long lastWriteTime) |
private static final long HEARTBEAT_MULTIPLIER
private final java.lang.String sessionId
@Nullable private final java.security.Principal user
private final MessageChannel clientOutboundChannel
private final long readInterval
private final long writeInterval
private volatile long lastReadTime
private volatile long lastWriteTime
public SessionInfo(java.lang.String sessionId, @Nullable java.security.Principal user, MessageChannel outboundChannel, @Nullable long[] clientHeartbeat, @Nullable long[] serverHeartbeat)
public java.lang.String getSessionId()
@Nullable public java.security.Principal getUser()
public MessageChannel getClientOutboundChannel()
public long getReadInterval()
public long getWriteInterval()
public long getLastReadTime()
public void setLastReadTime(long lastReadTime)
public long getLastWriteTime()
public void setLastWriteTime(long lastWriteTime)