Package io.netty.handler.codec.http.websocketx

Examples of io.netty.handler.codec.http.websocketx.TextWebSocketFrame

97
98
99
100
101
102
103
104
    public void invalidJsonInWebSocketFrame() throws Exception {
        final SockJsConfig config = SockJsConfig.withPrefix("/echo").build();
        final EmbeddedChannel ch = webSocketChannel(config);
        assertUpgradeRequest(ch);

        ch.writeInbound(new TextWebSocketFrame("[invalidJson"));
        assertThat(ch.isOpen(), is(false));
    }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
    public void writeJsonArray() throws Exception {
        final SockJsConfig config = SockJsConfig.withPrefix("/echo").build();
        final EmbeddedChannel ch = webSocketChannel(config);
        assertUpgradeRequest(ch);

        ch.writeInbound(new TextWebSocketFrame("[\"x\",\"y\"]"));
        // Discard of the HttpRequest
        ch.readInbound();
        final String x = ch.readInbound();
        assertThat(x, equalTo("x"));
        final String y = ch.readInbound();
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
    public void writeJsonString() throws Exception {
        final SockJsConfig config = SockJsConfig.withPrefix("/echo").build();
        final EmbeddedChannel ch = webSocketChannel(config);
        assertUpgradeRequest(ch);

        ch.writeInbound(new TextWebSocketFrame("\"x\""));
        // Discard of the HttpRequest
        ch.readInbound();
        final String message = ch.readInbound();
        assertThat(message, equalTo("x"));
    }
View Full Code Here
29
30
31
32
33
34
35
36
37
    @Test
    public void messageReceived() throws Exception {
        final EmbeddedChannel ch = createWebsocketChannel(SockJsConfig.withPrefix("/echo").build());
        ch.writeOutbound(new MessageFrame("testing"));
        final TextWebSocketFrame textFrame = ch.readOutbound();
        assertThat(textFrame.content().toString(CharsetUtil.UTF_8), equalTo("a[\"testing\"]"));
        textFrame.release();
    }
View Full Code Here
24
25
26
27
28
29
30
    Object value = cache.get(key);
   
    JSONObject responseObject = toJSON(key, value, cache.getName());
   
    // Write the JSON response out onto the channel...
    ctx.channel().writeAndFlush(new TextWebSocketFrame(responseObject.toString()));
  }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
96
97
    String jsonString = jsonObject.toString();
    for(ChannelNotifyParams channel : channels) {
      if(channel.channel.isOpen() && channel.onEvents.contains(eventType)) {
        if(channel.key != null) {
          if(event.getKey().equals(channel.key) || channel.key.equals("*")) {
            channel.channel.writeAndFlush(new TextWebSocketFrame(jsonString));
          }
        } else {         
          channel.channel.writeAndFlush(new TextWebSocketFrame(jsonString));
        }
      }
    }
  }
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
            JSONArray protocols = new JSONArray();
            protocols.put(PROTOCOL_VERSION_7);
            result.put(PROTOCOLS, protocols);
            result.put("serverName", "AEM Live Reload Server");

            channel.write(new TextWebSocketFrame(result.toString()));

            if (isSupported(obj)) {
                log.info("adding LiveReload channel");
                group.add(channel);
            }
View Full Code Here
175
176
177
178
179
180
181
182
    }

    public void triggerReload(String path) throws JSONException {
        if (group != null) {
            JSONObject reload = createReloadObject(path);
            group.flushAndWrite(new TextWebSocketFrame(reload.toString()), matcher);
        }
    }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
            handler.handshakeFuture().sync();

            // Send 10 messages and wait for responses
            System.out.println("WebSocket Client sending message");
            for (int i = 0; i < 10; i++) {
                ch.write(new TextWebSocketFrame("Message #" + i));
            }

            // Ping
            System.out.println("WebSocket Client sending ping");
            ch.write(new PingWebSocketFrame(Unpooled.copiedBuffer(new byte[]{1, 2, 3, 4, 5, 6})));
View Full Code Here
125
126
127
128
129
130
131
        // Send the uppercase string back.
        String request = ((TextWebSocketFrame) frame).text();
        if (logger.isLoggable(Level.FINE)) {
            logger.fine(String.format("Channel %s received %s", ctx.channel().id(), request));
        }
        ctx.channel().write(new TextWebSocketFrame(request.toUpperCase()));
    }
View Full Code Here
TOP

Related Classes of io.netty.handler.codec.http.websocketx.TextWebSocketFrame

  • com.adobe.acs.livereload.impl.LiveReloadServerImpl
  • com.adobe.acs.livereload.impl.WebSocketServerHandler
  • com.corundumstudio.socketio.handler.EncoderHandler
  • com.corundumstudio.socketio.SocketIOEncoder
  • com.corundumstudio.socketio.transport.WebSocketTransport
  • com.manning.nettyinaction.chapter11.TextWebSocketFrameHandler
  • com.manning.nettyinaction.chapter7.WebSocketConvertHandler
  • com.tinkerpop.gremlin.driver.handler.WebSocketGremlinRequestEncoder
  • com.tinkerpop.gremlin.driver.handler.WebSocketGremlinResponseDecoder
  • com.tinkerpop.gremlin.server.handler.WsGremlinResponseEncoder
    • Copyright © 2018 www.massapicom. 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.