org.jboss.errai.bus.client.api.QueueSession.addSessionEndListener()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(64)

本文整理了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

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) {

相关文章

微信公众号

最新文章

更多