gpt4 book ai didi

org.springframework.web.socket.WebSocketHandler.handleTransportError()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-26 20:47:05 27 4
gpt4 key购买 nike

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

WebSocketHandler.handleTransportError介绍

[英]Handle an error from the underlying WebSocket message transport.
[中]处理来自底层WebSocket消息传输的错误。

代码示例

代码示例来源:origin: spring-projects/spring-framework

public void delegateError(Throwable ex) throws Exception {
  this.handler.handleTransportError(this, ex);
}

代码示例来源:origin: spring-projects/spring-framework

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  this.delegate.handleTransportError(session, exception);
}

代码示例来源:origin: spring-projects/spring-framework

public void handleTransportError(Throwable error) {
  try {
    if (logger.isErrorEnabled()) {
      logger.error("Transport error in " + this, error);
    }
    this.webSocketHandler.handleTransportError(this, error);
  }
  catch (Throwable ex) {
    logger.error("WebSocketHandler.handleTransportError threw an exception", ex);
  }
}

代码示例来源:origin: spring-projects/spring-framework

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  getHandler(session).handleTransportError(session, exception);
}

代码示例来源:origin: spring-projects/spring-framework

@Override
public void onError(javax.websocket.Session session, Throwable exception) {
  try {
    this.handler.handleTransportError(this.wsSession, exception);
  }
  catch (Throwable ex) {
    ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
  }
}

代码示例来源:origin: spring-projects/spring-framework

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) {
  try {
    getDelegate().handleTransportError(session, exception);
  }
  catch (Throwable ex) {
    tryCloseWithError(session, ex, logger);
  }
}

代码示例来源:origin: spring-projects/spring-framework

@OnWebSocketError
public void onWebSocketError(Throwable cause) {
  try {
    this.webSocketHandler.handleTransportError(this.wsSession, cause);
  }
  catch (Throwable ex) {
    ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
  }
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void onError() throws Throwable {
  Exception exception = new Exception();
  this.adapter.onError(this.session, exception);
  verify(this.webSocketHandler).handleTransportError(this.webSocketSession, exception);
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void delegateError() throws Exception {
  Exception ex = new Exception();
  this.session.delegateError(ex);
  verify(this.webSocketHandler).handleTransportError(this.session, ex);
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void onError() throws Throwable {
  Exception exception = new Exception();
  this.adapter.onWebSocketError(exception);
  verify(this.webSocketHandler).handleTransportError(this.webSocketSession, exception);
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void webSocketTransportError() throws Exception {
  IllegalStateException exception = new IllegalStateException("simulated exception");
  connect().handleTransportError(this.webSocketSession, exception);
  verify(this.stompSession).handleFailure(same(exception));
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void handleMessageBadData() throws Exception {
  TextMessage message = new TextMessage("[\"x]");
  this.session.handleMessage(message, this.webSocketSession);
  this.session.isClosed();
  verify(this.webSocketHandler).handleTransportError(same(this.session), any(IOException.class));
  verifyNoMoreInteractions(this.webSocketHandler);
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void handleTransportError() throws Exception {
  final IllegalStateException ex = new IllegalStateException("Fake error");
  this.session.handleTransportError(ex);
  verify(this.handler).handleTransportError(this.session, ex);
  verifyNoMoreInteractions(this.handler);
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void handleTransportError() throws Exception {
  Exception exception = new Exception("transport error");
  willThrow(new IllegalStateException("error"))
    .given(this.delegate).handleTransportError(this.session, exception);
  this.decorator.handleTransportError(this.session, exception);
  assertEquals(CloseStatus.SERVER_ERROR, this.session.getCloseStatus());
}

代码示例来源:origin: spring-projects/spring-framework

@Test
public void errorResponseStatus() throws Exception {
  connect(response(HttpStatus.OK, "o\n"), response(HttpStatus.INTERNAL_SERVER_ERROR, "Oops"));
  verify(this.webSocketHandler).afterConnectionEstablished(any());
  verify(this.webSocketHandler).handleTransportError(any(), any());
  verify(this.webSocketHandler).afterConnectionClosed(any(), any());
  verifyNoMoreInteractions(this.webSocketHandler);
}

代码示例来源:origin: org.springframework/spring-websocket

public void handleTransportError(Throwable error) {
  try {
    if (logger.isErrorEnabled()) {
      logger.error("Transport error in " + this, error);
    }
    this.webSocketHandler.handleTransportError(this, error);
  }
  catch (Throwable ex) {
    logger.error("WebSocketHandler.handleTransportError threw an exception", ex);
  }
}

代码示例来源:origin: apache/servicemix-bundles

public void handleTransportError(Throwable error) {
  try {
    if (logger.isErrorEnabled()) {
      logger.error("Transport error in " + this, error);
    }
    this.webSocketHandler.handleTransportError(this, error);
  }
  catch (Throwable ex) {
    logger.error("WebSocketHandler.handleTransportError threw an exception", ex);
  }
}

代码示例来源:origin: leangen/graphql-spqr-spring-boot-starter

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  getHandler(session).handleTransportError(session, exception);
}

代码示例来源:origin: apache/servicemix-bundles

@Override
public void onError(javax.websocket.Session session, Throwable exception) {
  try {
    this.handler.handleTransportError(this.wsSession, exception);
  }
  catch (Throwable ex) {
    ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
  }
}

代码示例来源:origin: org.springframework/spring-websocket

@Override
public void onError(javax.websocket.Session session, Throwable exception) {
  try {
    this.handler.handleTransportError(this.wsSession, exception);
  }
  catch (Throwable ex) {
    ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
  }
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com