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

WsSession.fireEndpointOnError介绍

暂无

代码示例

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

private void fireEndpointOnClose(CloseReason closeReason) {
  // Fire the onClose event
  Throwable throwable = null;
  InstanceManager instanceManager = webSocketContainer.getInstanceManager();
  Thread t = Thread.currentThread();
  ClassLoader cl = t.getContextClassLoader();
  t.setContextClassLoader(applicationClassLoader);
  try {
    localEndpoint.onClose(this, closeReason);
  } catch (Throwable t1) {
    ExceptionUtils.handleThrowable(t1);
    throwable = t1;
  } finally {
    if (instanceManager != null) {
      try {
        instanceManager.destroyInstance(localEndpoint);
      } catch (Throwable t2) {
        ExceptionUtils.handleThrowable(t2);
        if (throwable == null) {
          throwable = t2;
        }
      }
    }
    t.setContextClassLoader(cl);
  }
  if (throwable != null) {
    fireEndpointOnError(throwable);
  }
}

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

fireEndpointOnError(throwable);

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

fireEndpointOnError(throwable);

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

} catch (IOException e) {
  WebsocketsLogger.ROOT_LOGGER.flushOnCloseFailed(e);
  fireEndpointOnError(e);

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

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

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

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 *
 * @param closeReason The reason contained within the received close
 *                    message.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

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

} catch (IOException e) {
  log.warn(sm.getString("wsSession.flushFailOnClose"), e);
  fireEndpointOnError(e);

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

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 *
 * @param closeReason The reason contained within the received close
 *                    message.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

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

} catch (IOException e) {
  log.warn(sm.getString("wsSession.flushFailOnClose"), e);
  fireEndpointOnError(e);

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

} catch (IOException e) {
  log.warn(sm.getString("wsSession.flushFailOnClose"), e);
  fireEndpointOnError(e);

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

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state == State.OPEN) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        WebsocketsLogger.ROOT_LOGGER.flushOnCloseFailed(e);
        fireEndpointOnError(e);
      }
      if (!Constants.RELAXED_CLOSE_EVENT) {
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      } else {
        fireEndpointOnClose(closeReason);
        sendCloseMessage(closeReason);
      }
      state = State.CLOSED;
    }
    // Close the socket
    wsRemoteEndpoint.close();
  }
}