Constructor and Description |
---|
SessionImpl(String id,
SessionManager sessionManager,
TopicsContext topicsContext) |
Modifier and Type | Method and Description |
---|---|
void |
clearBroadcastedMessages(long sequenceNumber) |
void |
connect(Request request) |
void |
destroy() |
void |
disconnect() |
Map<TopicKey,String> |
getFailedSubscriptions() |
String |
getId() |
long |
getLastAccessedTime() |
int |
getMaxInactiveInterval() |
Collection<MessageData> |
getMessages() |
protected Request |
getRequest() |
Collection<TopicKey> |
getSuccessfulSubscriptions() |
void |
invalidate() |
Collection<MessageData> |
poll() |
protected void |
processConnect(Request request) |
void |
push(TopicKey topicKey,
String serializedData) |
void |
subscribe(String[] topics) |
public SessionImpl(String id, SessionManager sessionManager, TopicsContext topicsContext)
protected Request getRequest()
public void disconnect() throws Exception
disconnect
in interface Session
Exception
public long getLastAccessedTime()
getLastAccessedTime
in interface Session
public int getMaxInactiveInterval()
getMaxInactiveInterval
in interface Session
public void invalidate()
invalidate
in interface Session
public void destroy()
public Collection<MessageData> poll()
public Map<TopicKey,String> getFailedSubscriptions()
getFailedSubscriptions
in interface Session
public Collection<TopicKey> getSuccessfulSubscriptions()
getSuccessfulSubscriptions
in interface Session
public Collection<MessageData> getMessages()
getMessages
in interface Session
public void clearBroadcastedMessages(long sequenceNumber)
clearBroadcastedMessages
in interface Session
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.