Examples of io.undertow.io.Sender.send()

io.undertow.io.Sender.send()
Write the given buffer using async IO, and calls the given callback on completion or error. @param buffer The buffer to send. @param callback The callback

        if (displaySessionids) {
            printInfoSessions(buf, container.getSessionIds());
        }


        buf.append("</body></html>\n");
        resp.send(buf.toString());
    }


    private void processDomainCmd(HttpServerExchange exchange, String domain, Status status) throws Exception {
        for (Node nodeConfig : container.getNodes()) {
            if (nodeConfig.getNodeConfig().getDomain().equals(domain)) {

View Full Code Here

                String data = "Type=PING-RSP&State=OK";
                Sender resp = exchange.getResponseSender();
                ByteBuffer bb = ByteBuffer.allocate(data.length());
                bb.put(data.getBytes());
                bb.flip();
                resp.send(bb);
                return;
            } else {
                if (scheme == null || host == null || port == null) {
                    processError(TYPESYNTAX, SMISFLD, exchange);
                    return;

View Full Code Here


                Sender resp = exchange.getResponseSender();
                ByteBuffer bb = ByteBuffer.allocate(data.length());
                bb.put(data.getBytes());
                bb.flip();
                resp.send(bb);
                return;
            }
        } else {
            // ping the corresponding node.
            Node nodeConfig = container.getNode(jvmRoute);

View Full Code Here


            Sender resp = exchange.getResponseSender();
            ByteBuffer bb = ByteBuffer.allocate(data.length());
            bb.put(data.getBytes());
            bb.flip();
            resp.send(bb);
        }
    }


    private Map<String, String[]> readPostParameters(HttpServerExchange exchange) throws IOException {
        final Map<String, String[]> ret = new HashMap<>();

View Full Code Here

        Sender resp = exchange.getResponseSender();
        ByteBuffer bb = ByteBuffer.allocate(data.length());
        bb.put(data.getBytes());
        bb.flip();


        resp.send(bb);
        return;
    }


    private String processInfoString() {
        int i = 1;

View Full Code Here

        Sender resp = exchange.getResponseSender();
        ByteBuffer bb = ByteBuffer.allocate(data.length());
        bb.put(data.getBytes());
        bb.flip();


        resp.send(bb);
    }


    private String processDumpString() {
        StringBuilder data = new StringBuilder();
        int i = 1;

View Full Code Here

                    int sent = 0;


                    @Override
                    public void run() {
                        sent++;
                        sender.send("a", this);
                    }


                    @Override
                    public void onComplete(final HttpServerExchange exchange, final Sender sender) {
                        if (sent++ == SENDS) {

View Full Code Here

                    public void onComplete(final HttpServerExchange exchange, final Sender sender) {
                        if (sent++ == SENDS) {
                            sender.close();
                            return;
                        }
                        sender.send("a", this);
                    }


                    @Override
                    public void onException(final HttpServerExchange exchange, final Sender sender, final IOException exception) {
                        exception.printStackTrace();

View Full Code Here

            public void handleRequest(final HttpServerExchange exchange) throws Exception {
                if (connection == null) {
                    connection = exchange.getConnection();
                } else if (!DefaultServer.isAjp()  && !DefaultServer.isProxy() && connection != exchange.getConnection()) {
                    Sender sender = exchange.getResponseSender();
                    sender.send("Connection not persistent");
                    return;
                }
                exchange.getResponseHeaders().put(Headers.CONTENT_LENGTH, message.length() + "");
                final Sender sender = exchange.getResponseSender();
                sender.send(message);

View Full Code Here

                    sender.send("Connection not persistent");
                    return;
                }
                exchange.getResponseHeaders().put(Headers.CONTENT_LENGTH, message.length() + "");
                final Sender sender = exchange.getResponseSender();
                sender.send(message);
            }
        });
    }


    @Test

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.