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

WebSocketHandlerDecorator介绍

[英]Wraps another org.springframework.web.socket.WebSocketHandlerinstance and delegates to it.

Also provides a #getDelegate() method to return the decorated handler as well as a #getLastHandler() method to go through all nested delegates and return the "last" handler.
[中]包装另一个组织。springframework。网状物插座WebSocketHandlerinstance及其委托人。
还提供了一个#getDelegate（）方法来返回修饰的处理程序，以及一个#getLastHandler（）方法来遍历所有嵌套的委托并返回“最后一个”处理程序。

代码示例

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

@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug("New "	+ session);
  }
  super.afterConnectionEstablished(session);
}

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

@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug(session + " closed with " + closeStatus);
  }
  super.afterConnectionClosed(session, closeStatus);
}

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

@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
  if (logger.isTraceEnabled()) {
    logger.trace("Handling " + message + " in " + session);
  }
  super.handleMessage(session, message);
}

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

@Test
public void getLastHandler() {
  AbstractWebSocketHandler h1 = new AbstractWebSocketHandler() {
  };
  WebSocketHandlerDecorator h2 = new WebSocketHandlerDecorator(h1);
  WebSocketHandlerDecorator h3 = new WebSocketHandlerDecorator(h2);
  assertSame(h1, h3.getLastHandler());
}

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

private static SubProtocolWebSocketHandler unwrapSubProtocolWebSocketHandler(WebSocketHandler handler) {
  WebSocketHandler actual = WebSocketHandlerDecorator.unwrap(handler);
  if (!(actual instanceof SubProtocolWebSocketHandler)) {
    throw new IllegalArgumentException("No SubProtocolWebSocketHandler in " + handler);
  }
  return (SubProtocolWebSocketHandler) actual;
}

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

public static WebSocketHandler unwrap(WebSocketHandler handler) {
  if (handler instanceof WebSocketHandlerDecorator) {
    return ((WebSocketHandlerDecorator) handler).getLastHandler();
  }
  else {
    return handler;
  }
}

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

public WebSocketHandler getLastHandler() {
  WebSocketHandler result = this.delegate;
  while (result instanceof WebSocketHandlerDecorator) {
    result = ((WebSocketHandlerDecorator) result).getDelegate();
  }
  return result;
}

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

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug("Transport error in " + session, exception);
  }
  super.handleTransportError(session, exception);
}

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

public SockJsWebSocketHandler(SockJsServiceConfig serviceConfig, WebSocketHandler webSocketHandler,
    WebSocketServerSockJsSession sockJsSession) {
  Assert.notNull(serviceConfig, "serviceConfig must not be null");
  Assert.notNull(webSocketHandler, "webSocketHandler must not be null");
  Assert.notNull(sockJsSession, "session must not be null");
  this.sockJsServiceConfig = serviceConfig;
  this.sockJsSession = sockJsSession;
  webSocketHandler = WebSocketHandlerDecorator.unwrap(webSocketHandler);
  this.subProtocols = ((webSocketHandler instanceof SubProtocolCapable) ?
      new ArrayList<>(((SubProtocolCapable) webSocketHandler).getSubProtocols()) : Collections.emptyList());
}

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

private WebSocketHandler unwrapWebSocketHandler(WebSocketHandler handler) {
  return (handler instanceof WebSocketHandlerDecorator) ?
      ((WebSocketHandlerDecorator) handler).getLastHandler() : handler;
}

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

@Test
public void openConnection() throws Exception {
  List<String> subprotocols = Arrays.asList("abc");
  TestLifecycleWebSocketClient client = new TestLifecycleWebSocketClient(false);
  WebSocketHandler handler = new TextWebSocketHandler();
  WebSocketConnectionManager manager = new WebSocketConnectionManager(client, handler , "/path/{id}", "123");
  manager.setSubProtocols(subprotocols);
  manager.openConnection();
  WebSocketHttpHeaders expectedHeaders = new WebSocketHttpHeaders();
  expectedHeaders.setSecWebSocketProtocol(subprotocols);
  assertEquals(expectedHeaders, client.headers);
  assertEquals(new URI("/path/123"), client.uri);
  WebSocketHandlerDecorator loggingHandler = (WebSocketHandlerDecorator) client.webSocketHandler;
  assertEquals(LoggingWebSocketHandlerDecorator.class, loggingHandler.getClass());
  assertSame(handler, loggingHandler.getDelegate());
}

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

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug("Transport error in " + session, exception);
  }
  super.handleTransportError(session, exception);
}

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

@Override
  public void afterConnectionEstablished(WebSocketSession session) throws Exception {
    session.getAttributes().put("decorated", true);
    super.afterConnectionEstablished(session);
  }
}

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

@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug(session + " closed with " + closeStatus);
  }
  super.afterConnectionClosed(session, closeStatus);
}

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

/**
 * Determine the sub-protocols supported by the given WebSocketHandler by
 * checking whether it is an instance of {@link SubProtocolCapable}.
 * @param handler the handler to check
 * @return a list of supported protocols, or an empty list if none available
 */
protected final List<String> determineHandlerSupportedProtocols(WebSocketHandler handler) {
  WebSocketHandler handlerToCheck = WebSocketHandlerDecorator.unwrap(handler);
  List<String> subProtocols = null;
  if (handlerToCheck instanceof SubProtocolCapable) {
    subProtocols = ((SubProtocolCapable) handlerToCheck).getSubProtocols();
  }
  return (subProtocols != null ? subProtocols : Collections.emptyList());
}

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

@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
  super.handleMessage(session, message);
}

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

private static void unwrapAndCheckDecoratedHandlerType(WebSocketHandler handler, Class<?> handlerClass) {
    if (handler instanceof WebSocketHandlerDecorator) {
      handler = ((WebSocketHandlerDecorator) handler).getLastHandler();
    }
    assertTrue(handlerClass.isInstance(handler));
  }
}

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

public WebSocketHandler getLastHandler() {
  WebSocketHandler result = this.delegate;
  while (result instanceof WebSocketHandlerDecorator) {
    result = ((WebSocketHandlerDecorator) result).getDelegate();
  }
  return result;
}

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

@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  if (logger.isDebugEnabled()) {
    logger.debug("Transport error in " + session, exception);
  }
  super.handleTransportError(session, exception);
}

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

@Override
public void afterConnectionEstablished(WebSocketSession wsSession)
    throws Exception {
  super.afterConnectionEstablished(wsSession);
  publishEvent(new SessionConnectEvent(this, wsSession));
}