本文整理了Java中org.jboss.errai.bus.client.api.QueueSession.addSessionEndListener
方法的一些代码示例,展示了QueueSession.addSessionEndListener
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueueSession.addSessionEndListener
方法的具体详情如下:
包路径:org.jboss.errai.bus.client.api.QueueSession
类名称:QueueSession
方法名:addSessionEndListener
[英]Registers a listener that will notified when this session ends.
[中]注册一个侦听器,该侦听器将在该会话结束时收到通知。
代码示例来源:origin: org.jboss.errai/errai-bus
@Override
public QueueSession createOrGetSession(final HttpSession externSessRef, final String remoteQueueID) {
final SessionsContainer sc;
if (containersByHttpSessionId.containsKey(externSessRef.getId())) {
sc = containersByHttpSessionId.get(externSessRef.getId());
}
else {
sc = new SessionsContainer();
containersByHttpSessionId.put(externSessRef.getId(), sc);
csrfCheck.prepareSession(externSessRef, log);
}
QueueSession qs = sc.getSession(remoteQueueID);
if (qs == null) {
log.debug("queue session " + remoteQueueID + " started");
qs = sc.createSession(externSessRef.getId(), remoteQueueID);
qs.setAttribute(HttpSession.class.getName(), externSessRef);
qs.addSessionEndListener(new SessionEndListener() {
@Override
public void onSessionEnd(final SessionEndEvent event) {
log.debug("queue session " + remoteQueueID + " ended");
sc.removeSession(remoteQueueID);
}
});
}
return qs;
}
代码示例来源:origin: errai/errai
@Override
public QueueSession createOrGetSession(final HttpSession externSessRef, final String remoteQueueID) {
final SessionsContainer sc;
if (containersByHttpSessionId.containsKey(externSessRef.getId())) {
sc = containersByHttpSessionId.get(externSessRef.getId());
}
else {
sc = new SessionsContainer();
containersByHttpSessionId.put(externSessRef.getId(), sc);
csrfCheck.prepareSession(externSessRef, log);
}
QueueSession qs = sc.getSession(remoteQueueID);
if (qs == null) {
log.debug("queue session " + remoteQueueID + " started");
qs = sc.createSession(externSessRef.getId(), remoteQueueID);
qs.setAttribute(HttpSession.class.getName(), externSessRef);
qs.addSessionEndListener(new SessionEndListener() {
@Override
public void onSessionEnd(final SessionEndEvent event) {
log.debug("queue session " + remoteQueueID + " ended");
sc.removeSession(remoteQueueID);
}
});
}
return qs;
}
代码示例来源:origin: errai/errai
"Negotiation done for errai session: {} on websocket session: {}",
queueSession.getSessionId(), session.getId());
queueSession.addSessionEndListener(new SessionEndListener() {
@Override
public void onSessionEnd(SessionEndEvent event) {
代码示例来源:origin: org.jboss.errai/errai-bus-jsr356-websocket
"Negotiation done for errai session: {} on websocket session: {}",
queueSession.getSessionId(), session.getId());
queueSession.addSessionEndListener(new SessionEndListener() {
@Override
public void onSessionEnd(SessionEndEvent event) {
内容来源于网络,如有侵权,请联系作者删除!