Examples of WebSocketSession

io.undertow.websockets.api.WebSocketSession
Session for a WebSocket connection. For each new connection a {@link WebSocketSession} will be created.This {@link WebSocketSession} can then be used to communicate with the remote peer.
Implementations of the interface are expected to be thread-safe, however if multiple threads are sending messages no guarantees are provided about the resulting message order. @author Norman Maurer
org.eclipse.jetty.websocket.common.WebSocketSession
org.springframework.web.socket.WebSocketSession
A WebSocket session abstraction. Allows sending messages over a WebSocket connection and closing it. @author Rossen Stoyanchev @since 4.0

Examples of io.undertow.websockets.api.WebSocketSession

                                    @Override
                                    public void onTextFrame(final WebSocketSession session, final WebSocketFrameHeader header, final CharSequence payload) {
                                        synchronized (sessions) {
                                            Iterator<WebSocketSession> it = sessions.iterator();
                                            while (it.hasNext()) {
                                                final WebSocketSession sess = it.next();
                                                try {
                                                    sess.sendText(payload);
                                                } catch (IOException e) {
                                                    it.remove();
                                                }
                                            }
                                        }

View Full Code Here

Examples of io.undertow.websockets.api.WebSocketSession

                            @Override
                            public void onTextFrame(final WebSocketSession session, final WebSocketFrameHeader header, final CharSequence payload) {
                                synchronized (sessions) {
                                    Iterator<WebSocketSession> it = sessions.iterator();
                                    while (it.hasNext()) {
                                        final WebSocketSession sess = it.next();
                                        try {
                                            sess.sendText(payload);
                                        } catch (IOException e) {
                                            it.remove();
                                        }
                                    }
                                }

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

    public void onOpen()
    {
        boolean beenOpened = opened.getAndSet(true);
        if (!beenOpened)
        {
            WebSocketSession session = getSession();
            ConnectionManager connectionManager = connectPromise.getClient().getConnectionManager();
            connectionManager.addSession(session);
            connectPromise.succeeded(session);


            ByteBuffer extraBuf = connectPromise.getResponse().getRemainingBuffer();

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

        WebSocketPolicy policy = websocket.getPolicy();


        WebSocketClientConnection connection = new WebSocketClientConnection(endp,executor,connectPromise,policy);


        SessionFactory sessionFactory = connectPromise.getClient().getSessionFactory();
        WebSocketSession session = sessionFactory.createSession(request.getRequestURI(),websocket,connection);
        session.setPolicy(policy);
        session.setUpgradeResponse(response);


        connection.setSession(session);


        // Initialize / Negotiate Extensions
        ExtensionStack extensionStack = new ExtensionStack(connectPromise.getClient().getExtensionFactory());
        extensionStack.negotiate(response.getExtensions());


        extensionStack.configure(connection.getParser());
        extensionStack.configure(connection.getGenerator());


        // Setup Incoming Routing
        connection.setNextIncomingFrames(extensionStack);
        extensionStack.setNextIncoming(session);


        // Setup Outgoing Routing
        session.setOutgoingHandler(extensionStack);
        extensionStack.setNextOutgoing(connection);


        session.addBean(extensionStack);
        connectPromise.getClient().addManaged(session);


        // Now swap out the connection
        endp.setConnection(connection);
        connection.onOpen();

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

            LOG.debug("HttpConnection: {}", http);
            LOG.debug("WebSocketConnection: {}", wsConnection);
        }


        // Setup Session
        WebSocketSession session = createSession(request.getRequestURI(), driver, wsConnection);
        session.setPolicy(driver.getPolicy());
        session.setUpgradeRequest(request);
        // set true negotiated extension list back to response 
        response.setExtensions(extensionStack.getNegotiatedExtensions());
        session.setUpgradeResponse(response);
        wsConnection.setSession(session);


        // Setup Incoming Routing
        wsConnection.setNextIncomingFrames(extensionStack);
        extensionStack.setNextIncoming(session);


        // Setup Outgoing Routing
        session.setOutgoingHandler(extensionStack);
        extensionStack.setNextOutgoing(wsConnection);


        // Start Components
        try
        {
            session.start();
        }
        catch (Exception e)
        {
            throw new IOException("Unable to start Session", e);
        }

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

        public EndPoint getEndPoint() throws Exception
        {
            Session session = getSession();
            Assert.assertThat("Session type",session,instanceOf(WebSocketSession.class));


            WebSocketSession wssession = (WebSocketSession)session;
            Field fld = wssession.getClass().getDeclaredField("connection");
            fld.setAccessible(true);
            Assert.assertThat("Field: connection",fld,notNullValue());


            Object val = fld.get(wssession);
            Assert.assertThat("Connection type",val,instanceOf(AbstractWebSocketConnection.class));

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

    public void onOpen()
    {
        boolean beenOpened = opened.getAndSet(true);
        if (!beenOpened)
        {
            WebSocketSession session = getSession();
            ConnectionManager connectionManager = connectPromise.getClient().getConnectionManager();
            connectionManager.addSession(session);
            connectPromise.succeeded(session);


            ByteBuffer extraBuf = connectPromise.getResponse().getRemainingBuffer();

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession

        WebSocketPolicy policy = websocket.getPolicy();


        WebSocketClientConnection connection = new WebSocketClientConnection(endp,executor,connectPromise,policy);


        SessionFactory sessionFactory = connectPromise.getClient().getSessionFactory();
        WebSocketSession session = sessionFactory.createSession(request.getRequestURI(),websocket,connection);
        session.setPolicy(policy);
        session.setUpgradeResponse(response);


        connection.setSession(session);


        // Initialize / Negotiate Extensions
        ExtensionStack extensionStack = new ExtensionStack(connectPromise.getClient().getExtensionFactory());
        extensionStack.negotiate(response.getExtensions());


        extensionStack.configure(connection.getParser());
        extensionStack.configure(connection.getGenerator());


        // Setup Incoming Routing
        connection.setNextIncomingFrames(extensionStack);
        extensionStack.setNextIncoming(session);


        // Setup Outgoing Routing
        session.setOutgoingHandler(extensionStack);
        extensionStack.setNextOutgoing(connection);


        session.addBean(extensionStack);
        connectPromise.getClient().addBean(session);


        // Now swap out the connection
        endp.setConnection(connection);
        connection.onOpen();

View Full Code Here

Examples of org.eclipse.jetty.websocket.common.WebSocketSession


        LOG.debug("HttpConnection: {}", http);
        LOG.debug("WebSocketConnection: {}", wsConnection);


        // Setup Session
        WebSocketSession session = createSession(request.getRequestURI(), driver, wsConnection);
        session.setPolicy(driver.getPolicy());
        session.setUpgradeRequest(request);
        // set true negotiated extension list back to response 
        response.setExtensions(extensionStack.getNegotiatedExtensions());
        session.setUpgradeResponse(response);
        wsConnection.setSession(session);


        // Setup Incoming Routing
        wsConnection.setNextIncomingFrames(extensionStack);
        extensionStack.setNextIncoming(session);


        // Setup Outgoing Routing
        session.setOutgoingHandler(extensionStack);
        extensionStack.setNextOutgoing(wsConnection);


        // Start Components
        try
        {
            session.start();
        }
        catch (Exception e)
        {
            throw new IOException("Unable to start Session", e);
        }

View Full Code Here

Examples of org.springframework.web.socket.WebSocketSession


      log.info("SessionId: " + client.getSession().getSessionId());


      JsonRpcClientWebSocket webSocketClient = (JsonRpcClientWebSocket) client;


      WebSocketSession session = webSocketClient.getWebSocketSession();
      session.close();


      Assert.assertEquals("old",
          client.sendRequest("sessiontest", String.class));
      Assert.assertEquals("old",
          client.sendRequest("sessiontest", String.class));

View Full Code Here

0 1 2 3 4

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.