Examples of WebSocketHandler

org.eclipse.jetty.websocket.WebSocketHandler
org.eclipse.jetty.websocket.server.WebSocketHandler
org.jboss.errai.bus.client.framework.transports.WebsocketHandler
@author Mike Brock
org.springframework.web.socket.WebSocketHandler
A handler for WebSocket messages and lifecycle events.
Implementations of this interface are encouraged to handle exceptions locally where it makes sense or alternatively let the exception bubble up in which case by default the exception is logged and the session closed with {@link CloseStatus#SERVER_ERROR SERVER_ERROR(1011)}. The exception handling strategy is provided by {@link org.springframework.web.socket.handler.ExceptionWebSocketHandlerDecorator ExceptionWebSocketHandlerDecorator} and it can be customized or replaced by decoratingthe {@link WebSocketHandler} with a different decorator. @author Rossen Stoyanchev @author Phillip Webb @since 4.0
org.webbitserver.WebSocketHandler

Examples of org.eclipse.jetty.websocket.WebSocketHandler

      connector.setReuseAddress(false);
      connector.setSoLingerTime(0);
  
      Server server = new Server();
      server.addConnector(connector);
      server.setHandler(new WebSocketHandler() 
      {
        @Override
        public WebSocket doWebSocketConnect(HttpServletRequest arg0, String arg1) 
        {
          return new WebSocket()

View Full Code Here

Examples of org.eclipse.jetty.websocket.WebSocketHandler

    public WebsocketServer(int port) throws URISyntaxException {
        SelectChannelConnector connector = new SelectChannelConnector();
        connector.setPort(port);
        addConnector(connector);


        setHandler(new WebSocketHandler() {


            @Override
            public WebSocket doWebSocketConnect(HttpServletRequest request, String protocol) {
                return new TuscanyWebsocket(dispatcher);
            }

View Full Code Here

Examples of org.eclipse.jetty.websocket.WebSocketHandler

            connector.setHost(bindingAddress.trim());
        }
        connector.setPort(_port.getPort());
        _server.addConnector(connector);


        WebSocketHandler wshandler = new WebSocketHandler()
        {
            @Override
            public WebSocket doWebSocketConnect(final HttpServletRequest request, final String protocol)
            {

View Full Code Here

Examples of org.eclipse.jetty.websocket.WebSocketHandler

        }


        connector.setPort(_port.getPort());
        _server.addConnector(connector);


        WebSocketHandler wshandler = new WebSocketHandler()
        {
            @Override
            public WebSocket doWebSocketConnect(final HttpServletRequest request, final String protocol)
            {

View Full Code Here

Examples of org.eclipse.jetty.websocket.server.WebSocketHandler

        server = new Server();
        connector = new ServerConnector(server);
        connector.setPort(port);
        server.addConnector(connector);


        WebSocketHandler wsHandler = new WebSocketHandler()
        {
            @Override
            public void configure(WebSocketServletFactory factory)
            {
                LOG.debug("Configuring WebSocketServerFactory ...");


                // factory.getExtensionFactory().unregister("deflate-frame");
                // factory.getExtensionFactory().unregister("permessage-deflate");
                factory.getExtensionFactory().register("permessage-deflate",PerMessageDeflateExtension.class);
                // factory.getExtensionFactory().unregister("x-webkit-deflate-frame");


                // Registering Frame Debug
                factory.getExtensionFactory().register("@frame-debug",FrameDebugExtension.class);


                // Setup the desired Socket to use for all incoming upgrade requests
                factory.setCreator(BrowserDebugTool.this);


                // Set the timeout
                factory.getPolicy().setIdleTimeout(30000);


                // Set top end message size
                factory.getPolicy().setMaxTextMessageSize(15 * 1024 * 1024);
            }
        };


        server.setHandler(wsHandler);


        String resourceBase = "src/test/resources/browser-debug-tool";


        ResourceHandler rHandler = new ResourceHandler();
        rHandler.setDirectoriesListed(true);
        rHandler.setResourceBase(resourceBase);
        wsHandler.setHandler(rHandler);


        LOG.info("{} setup on port {}",this.getClass().getName(),port);
    }

View Full Code Here

Examples of org.jboss.errai.bus.client.framework.transports.WebsocketHandler

        handler.close();
      }
    }


    Map<String, TransportHandler> m = new LinkedHashMap<String, TransportHandler>();
    m.put(Capabilities.WebSockets.name(), new WebsocketHandler(transportToBusCallback, ClientMessageBusImpl.this));
    m.put(Capabilities.SSE.name(), new SSEHandler(transportToBusCallback, ClientMessageBusImpl.this));
    m.put(Capabilities.LongPolling.name(),
            HttpPollingHandler.newLongPollingInstance(transportToBusCallback, ClientMessageBusImpl.this));
    m.put(Capabilities.ShortPolling.name(),
            HttpPollingHandler.newShortPollingInstance(transportToBusCallback, ClientMessageBusImpl.this));

View Full Code Here

Examples of org.jboss.errai.bus.client.framework.transports.WebsocketHandler

        handler.close();
      }
    }


    Map<String, TransportHandler> m = new LinkedHashMap<String, TransportHandler>();
    m.put(Capabilities.WebSockets.name(), new WebsocketHandler(ClientMessageBusImpl.this));
    m.put(Capabilities.SSE.name(), new SSEHandler(ClientMessageBusImpl.this));
    m.put(Capabilities.LongPolling.name(),
            HttpPollingHandler.newLongPollingInstance(ClientMessageBusImpl.this));
    m.put(Capabilities.ShortPolling.name(),
            HttpPollingHandler.newShortPollingInstance(ClientMessageBusImpl.this));

View Full Code Here

Examples of org.jboss.errai.bus.client.framework.transports.WebsocketHandler

  }


  private void setupDefaultHandlers() {
    availableHandlers = Collections.unmodifiableMap(new LinkedHashMap<String, TransportHandler>() {
      {
        put(Capabilities.WebSockets.name(), new WebsocketHandler(transportToBusCallback, ClientMessageBusImpl.this));
        put(Capabilities.SSE.name(), new SSEHandler(transportToBusCallback, ClientMessageBusImpl.this));
        put(Capabilities.LongPolling.name(),
            HttpPollingHandler.newLongPollingInstance(transportToBusCallback, ClientMessageBusImpl.this));
        put(Capabilities.ShortPolling.name(),
            HttpPollingHandler.newShortPollingInstance(transportToBusCallback, ClientMessageBusImpl.this));

View Full Code Here

Examples of org.jboss.errai.bus.client.framework.transports.WebsocketHandler

        handler.close();
      }
    }


    Map<String, TransportHandler> m = new LinkedHashMap<String, TransportHandler>();
    m.put(Capabilities.WebSockets.name(), new WebsocketHandler(ClientMessageBusImpl.this));
    m.put(Capabilities.SSE.name(), new SSEHandler(ClientMessageBusImpl.this));
    m.put(Capabilities.LongPolling.name(),
            HttpPollingHandler.newLongPollingInstance(ClientMessageBusImpl.this));
    m.put(Capabilities.ShortPolling.name(),
            HttpPollingHandler.newShortPollingInstance(ClientMessageBusImpl.this));

View Full Code Here

Examples of org.springframework.web.socket.WebSocketHandler

  @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();

View Full Code Here

0 1 2 3 4 5

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.