Examples of org.springframework.web.socket.WebSocketSession.sendMessage()

Class org.springframework.web.socket.WebSocketSession

Examples of org.springframework.web.socket.WebSocketSession.sendMessage()

org.springframework.web.socket.WebSocketSession.sendMessage()
Send a WebSocket message: either {@link TextMessage} or {@link BinaryMessage}.

      return;
    }


    try {
      if (session.isOpen()) {
        session.sendMessage(new TextMessage(json));
      } else {
        sessions.remove(session.getId());
      }
    } catch (IOException e) {
      logger.error("Sending of message '" + json + "' failed", e);

View Full Code Here

    TestClientHandler handler = new TestClientHandler();
    initSockJsClient(createWebSocketTransport(), createXhrTransport());
    WebSocketSession session = this.sockJsClient.doHandshake(handler, this.baseUrl + "/echo").get();
    assertEquals("Fallback didn't occur", XhrClientSockJsSession.class, session.getClass());
    TextMessage message = new TextMessage("message1");
    session.sendMessage(message);
    handler.awaitMessage(message, 5000);
  }


  @Test(timeout = 5000)
  public void fallbackAfterConnectTimeout() throws Exception {

View Full Code Here

    initSockJsClient(createXhrTransport());
    this.sockJsClient.setConnectTimeoutScheduler(this.wac.getBean(ThreadPoolTaskScheduler.class));
    WebSocketSession clientSession = sockJsClient.doHandshake(clientHandler, this.baseUrl + "/echo").get();
    assertEquals("Fallback didn't occur", XhrClientSockJsSession.class, clientSession.getClass());
    TextMessage message = new TextMessage("message1");
    clientSession.sendMessage(message);
    clientHandler.awaitMessage(message, 5000);
    clientSession.close();
  }

View Full Code Here

    }
    TestClientHandler handler = new TestClientHandler();
    initSockJsClient(transport);
    WebSocketSession session = this.sockJsClient.doHandshake(handler, this.baseUrl + "/echo").get();
    for (TextMessage message : messages) {
      session.sendMessage(message);
    }
    handler.awaitMessageCount(messageCount, 5000);
    for (TextMessage message : messages) {
      assertTrue("Message not received: " + message, handler.receivedMessages.remove(message));
    }

View Full Code Here

TOP

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.