javax.websocket.Session.getMessageHandlers()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(284)

本文整理了Java中javax.websocket.Session.getMessageHandlers()方法的一些代码示例,展示了Session.getMessageHandlers()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Session.getMessageHandlers()方法的具体详情如下:
包路径:javax.websocket.Session
类名称:Session
方法名:getMessageHandlers

Session.getMessageHandlers介绍

[英]Return an unmodifiable copy of the set of MessageHandlers for this Session.
[中]返回此会话的MessageHandler集的不可修改副本。

代码示例

代码示例来源:origin: org.chtijbug.drools/drools-platform-knowledge

public void closeSession() throws IOException {
  if (this.session != null) {
    if (this.session.isOpen() == true) {
      if (this.session.getMessageHandlers().size() > 0) {
        for (MessageHandler messageHandler : this.session.getMessageHandlers()) {
          this.session.removeMessageHandler(messageHandler);
        }
      }
      this.session.close();
    }
  }
}

代码示例来源:origin: org.apache.tomcat/tomcat-websocket

@Override
public final void onClose(Session session, CloseReason closeReason) {
  if (methodMapping.getOnClose() != null) {
    try {
      methodMapping.getOnClose().invoke(pojo,
          methodMapping.getOnCloseArgs(pathParameters, session, closeReason));
    } catch (Throwable t) {
      log.error(sm.getString("pojoEndpointBase.onCloseFail",
          pojo.getClass().getName()), t);
      handleOnOpenOrCloseError(session, t);
    }
  }
  // Trigger the destroy method for any associated decoders
  Set<MessageHandler> messageHandlers = session.getMessageHandlers();
  for (MessageHandler messageHandler : messageHandlers) {
    if (messageHandler instanceof PojoMessageHandlerWholeBase<?>) {
      ((PojoMessageHandlerWholeBase<?>) messageHandler).onClose();
    }
  }
}

代码示例来源:origin: org.apache.tomcat.embed/tomcat-embed-websocket

@Override
public final void onClose(Session session, CloseReason closeReason) {
  if (methodMapping.getOnClose() != null) {
    try {
      methodMapping.getOnClose().invoke(pojo,
          methodMapping.getOnCloseArgs(pathParameters, session, closeReason));
    } catch (Throwable t) {
      log.error(sm.getString("pojoEndpointBase.onCloseFail",
          pojo.getClass().getName()), t);
      handleOnOpenOrCloseError(session, t);
    }
  }
  // Trigger the destroy method for any associated decoders
  Set<MessageHandler> messageHandlers = session.getMessageHandlers();
  for (MessageHandler messageHandler : messageHandlers) {
    if (messageHandler instanceof PojoMessageHandlerWholeBase<?>) {
      ((PojoMessageHandlerWholeBase<?>) messageHandler).onClose();
    }
  }
}

代码示例来源:origin: org.apache.tomcat/tomcat7-websocket

@Override
public final void onClose(Session session, CloseReason closeReason) {
  if (methodMapping.getOnClose() != null) {
    try {
      methodMapping.getOnClose().invoke(pojo,
          methodMapping.getOnCloseArgs(pathParameters, session, closeReason));
    } catch (Throwable t) {
      ExceptionUtils.handleThrowable(t);
      log.error(sm.getString("pojoEndpointBase.onCloseFail",
          pojo.getClass().getName()), t);
    }
  }
  // Trigger the destroy method for any associated decoders
  Set<MessageHandler> messageHandlers = session.getMessageHandlers();
  for (MessageHandler messageHandler : messageHandlers) {
    if (messageHandler instanceof PojoMessageHandlerWholeBase<?>) {
      ((PojoMessageHandlerWholeBase<?>) messageHandler).onClose();
    }
  }
}

代码示例来源:origin: codefollower/Tomcat-Research

@Override
public final void onClose(Session session, CloseReason closeReason) {
  if (methodMapping.getOnClose() != null) {
    try {
      methodMapping.getOnClose().invoke(pojo,
          methodMapping.getOnCloseArgs(pathParameters, session, closeReason));
    } catch (Throwable t) {
      ExceptionUtils.handleThrowable(t);
      log.error(sm.getString("pojoEndpointBase.onCloseFail",
          pojo.getClass().getName()), t);
    }
  }
  // Trigger the destroy method for any associated decoders
  Set<MessageHandler> messageHandlers = session.getMessageHandlers();
  for (MessageHandler messageHandler : messageHandlers) {
    if (messageHandler instanceof PojoMessageHandlerWholeBase<?>) {
      ((PojoMessageHandlerWholeBase<?>) messageHandler).onClose();
    }
  }
}

代码示例来源:origin: org.jboss.web/jbossweb

Set<MessageHandler> messageHandlers = session.getMessageHandlers();
for (MessageHandler messageHandler : messageHandlers) {
  if (messageHandler instanceof PojoMessageHandlerWholeBase<?>) {

相关文章