Package io.netty.handler.codec.http

Examples of io.netty.handler.codec.http.FullHttpResponse.data()

270
271
272
273
274
275
276
277
278
279
280
            buf.append("</a></li>\r\n");
        }

        buf.append("</ul></body></html>\r\n");

        response.data().writeBytes(Unpooled.copiedBuffer(buf, CharsetUtil.UTF_8));

        // Close the connection as soon as the error message is sent.
        ctx.write(response).addListener(ChannelFutureListener.CLOSE);
    }
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
            long c = req.data().readLong();
            ByteBuf input = Unpooled.buffer(16);
            input.writeInt(a);
            input.writeInt(b);
            input.writeLong(c);
            res.data().writeBytes(WebSocketUtil.md5(input.array()));
        } else {
            // Old Hixie 75 handshake getMethod with no challenge:
            res.headers().add(WEBSOCKET_ORIGIN, req.headers().get(ORIGIN));
            res.headers().add(WEBSOCKET_LOCATION, uri());
            String protocol = req.headers().get(WEBSOCKET_PROTOCOL);
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
        }

        if (msg instanceof FullHttpResponse) {
            FullHttpResponse response = (FullHttpResponse) msg;
            throw new Exception("Unexpected FullHttpResponse (getStatus=" + response.getStatus() + ", content="
                    + response.data().toString(CharsetUtil.UTF_8) + ')');
        }

        WebSocketFrame frame = (WebSocketFrame) msg;
        if (frame instanceof TextWebSocketFrame) {
            TextWebSocketFrame textFrame = (TextWebSocketFrame) frame;
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
        response.headers().set(CONTENT_TYPE, "text/plain; charset=UTF-8");

        if (keepAlive) {
            // Add 'Content-Length' header only for a keep-alive connection.
            response.headers().set(CONTENT_LENGTH, response.data().readableBytes());
            // Add keep alive header as per:
            // - http://www.w3.org/Protocols/HTTP/1.1/draft-ietf-http-v11-spec-01.html#Connection
            response.headers().set(CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
        }
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
              cause.getStatus());

      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,
          content.readableBytes());

      response.data().writeBytes(content);

      ctx.write(response).addListener(ChannelFutureListener.CLOSE);

    }
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
                HttpResponseStatus.SERVICE_UNAVAILABLE);

        response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,
            content.readableBytes());

        response.data().writeBytes(content);

        context.write(response)
            .addListener(ChannelFutureListener.CLOSE);

        return;
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.