| 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 SessionExceptionpublic long getLastAccessedTime()
getLastAccessedTime in interface Sessionpublic int getMaxInactiveInterval()
getMaxInactiveInterval in interface Sessionpublic void invalidate()
invalidate in interface Sessionpublic void destroy()
public Collection<MessageData> poll()
public Map<TopicKey,String> getFailedSubscriptions()
getFailedSubscriptions in interface Sessionpublic Collection<TopicKey> getSuccessfulSubscriptions()
getSuccessfulSubscriptions in interface Sessionpublic Collection<MessageData> getMessages()
getMessages in interface Sessionpublic void clearBroadcastedMessages(long sequenceNumber)
clearBroadcastedMessages in interface SessionCopyright © 2014 JBoss by Red Hat. All rights reserved.