Examples of io.undertow.client.ClientConnection

io.undertow.client.ClientConnection
A client connection. This can be used to send requests, or to upgrade the connection.
In general these objects are not thread safe, they should only be used by the IO thread that is responsible for the connection. As a result this client does not provide a mechanism to perform blocking IO, it is designed for async operation only. @author Stuart Douglas

                            connection.putAttachment(exclusiveConnectionKey, newHolder);
                            connection.addCloseListener(new ServerConnection.CloseListener() {


                                @Override
                                public void closed(ServerConnection connection) {
                                    ClientConnection clientConnection = newHolder.connection.getConnection();
                                    if (clientConnection.isOpen()) {
                                        safeClose(clientConnection);
                                    }
                                }
                            });
                        }

View Full Code Here

    private void returnConnection(final ClientConnection connection) {
        HostThreadData hostData = getData();
        if (closed) {
            //the host has been closed
            IoUtils.safeClose(connection);
            ClientConnection con = hostData.availableConnections.poll();
            while (con != null) {
                IoUtils.safeClose(con);
                con = hostData.availableConnections.poll();
            }
            redistributeQueued(hostData);

View Full Code Here

    /**
     * @param exclusive - Is connection for the exclusive use of one client?
     */
    public void connect(ProxyClient.ProxyTarget proxyTarget, HttpServerExchange exchange, ProxyCallback<ProxyConnection> callback, final long timeout, final TimeUnit timeUnit, boolean exclusive) {
        HostThreadData data = getData();
        ClientConnection conn = data.availableConnections.poll();
        while (conn != null && !conn.isOpen()) {
            conn = data.availableConnections.poll();
        }
        if (conn != null) {
            if (exclusive) {
                data.connections--;

View Full Code Here

0 1 2 3 4 5

TOP

Related Classes of io.undertow.client.ClientConnection

io.undertow.client.http.HttpClientTestCase

io.undertow.server.handlers.proxy.Host

io.undertow.server.handlers.proxy.LoadBalancingProxyClient

io.undertow.server.handlers.proxy.mod_cluster.ModClusterLoadBalancingProxyClient

io.undertow.server.handlers.proxy.mod_cluster.ModClusterProxyClient

io.undertow.server.handlers.proxy.ProxyConnectionPool

io.undertow.server.handlers.proxy.ProxyHandler

io.undertow.server.handlers.proxy.ProxyHandler$ProxyClientHandler

io.undertow.server.handlers.proxy.SimpleProxyClientProvider

org.springframework.web.socket.sockjs.client.UndertowXhrTransport

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.