Examples of WebSocketServerSockJsSession


Examples of org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession

  @Override
  public AbstractSockJsSession createSession(String sessionId, WebSocketHandler handler,
      Map<String, Object> attributes) {

    return new WebSocketServerSockJsSession(sessionId, getServiceConfig(), handler, attributes);
  }
View Full Code Here

Examples of org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession

  @Override
  public void handleRequest(ServerHttpRequest request, ServerHttpResponse response,
      WebSocketHandler wsHandler, SockJsSession wsSession) throws SockJsException {

    WebSocketServerSockJsSession sockJsSession = (WebSocketServerSockJsSession) wsSession;
    try {
      wsHandler = new SockJsWebSocketHandler(getServiceConfig(), wsHandler, sockJsSession);
      this.handshakeHandler.doHandshake(request, response, wsHandler, Collections.<String, Object>emptyMap());
    }
    catch (Throwable ex) {
      sockJsSession.tryCloseWithSockJsTransportError(ex, CloseStatus.SERVER_ERROR);
      throw new SockJsTransportFailureException("WebSocket handshake failure", wsSession.getId(), ex);
    }
  }
View Full Code Here

Examples of org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession

    StompSubProtocolHandler stompHandler = new StompSubProtocolHandler();
    handler.addProtocolHandler(stompHandler);

    TaskScheduler scheduler = mock(TaskScheduler.class);
    DefaultSockJsService service = new DefaultSockJsService(scheduler);
    WebSocketServerSockJsSession session = new WebSocketServerSockJsSession("1", service, handler, null);
    SockJsWebSocketHandler sockJsHandler = new SockJsWebSocketHandler(service, handler, session);

    assertEquals(stompHandler.getSupportedProtocols(), sockJsHandler.getSubProtocols());
  }
View Full Code Here

Examples of org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession

  @Test
  public void getSubProtocolsNone() throws Exception {
    WebSocketHandler handler = new TextWebSocketHandler();
    TaskScheduler scheduler = mock(TaskScheduler.class);
    DefaultSockJsService service = new DefaultSockJsService(scheduler);
    WebSocketServerSockJsSession session = new WebSocketServerSockJsSession("1", service, handler, null);
    SockJsWebSocketHandler sockJsHandler = new SockJsWebSocketHandler(service, handler, session);

    assertNull(sockJsHandler.getSubProtocols());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.