Examples of shutdown()

Examples of org.apache.http.nio.NHttpClientConnection.shutdown()

233
234
235
236
237
238
239
240
241
242
243
    private void discardConnection() {
        final NHttpClientConnection localConn = this.managedConn.getAndSet(null);
        if (localConn != null) {
            try {
                localConn.shutdown();
                if (this.log.isDebugEnabled()) {
                    this.log.debug("[exchange: " + this.state.getId() + "] connection aborted");
                }
            } catch (final IOException ex) {
                if (this.log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.http.nio.client.HttpAsyncClient.shutdown()

64
65
66
67
68
69
70
71
72
73
74
            } else {
                System.out.println("Request failed");
            }
            System.out.println("Shutting down");
        } finally {
            httpclient.shutdown();
        }
        System.out.println("Done");
    }

    static class MyRequestProducer implements HttpAsyncRequestProducer {
View Full Code Here

Examples of org.apache.http.nio.conn.ClientAsyncConnection.shutdown()

122
123
124
125
126
127
128
129
130
131
132
    }

    public void shutdown() throws IOException {
        ClientAsyncConnection conn = getConnection();
        if (conn != null) {
            conn.shutdown();
        }
    }

    public boolean isOpen() {
        ClientAsyncConnection conn = getConnection();
View Full Code Here

Examples of org.apache.http.nio.conn.ManagedNHttpClientConnection.shutdown()

65
66
67
68
69
70
71
72
73
74
75
        conn.close();
    }

    public void shutdownConnection() throws IOException {
        final ManagedNHttpClientConnection conn = getConnection();
        conn.shutdown();
    }

    @Override
    public boolean isExpired(final long now) {
        final boolean expired = super.isExpired(now);
View Full Code Here

Examples of org.apache.http.nio.conn.OperatedAsyncClientConnection.shutdown()

122
123
124
125
126
127
128
129
130
131
132
    }

    public void shutdown() throws IOException {
        OperatedAsyncClientConnection conn = getConnection();
        if (conn != null) {
            conn.shutdown();
        }
    }

    public boolean isOpen() {
        OperatedAsyncClientConnection conn = getConnection();
View Full Code Here

Examples of org.apache.http.nio.protocol.AsyncHttpService.shutdown()

208
209
210
211
212
213
214
215
216
217
218
        }

        public void closed(final NHttpServerConnection conn) {
            AsyncHttpService httpService = (AsyncHttpService) conn.getContext()
                .getAttribute(HTTP_ASYNC_SERVICE);
            httpService.shutdown();
        }

        public void exception(final NHttpServerConnection conn, final HttpException httpex) {
            AsyncHttpService httpService = (AsyncHttpService) conn.getContext()
                .getAttribute(HTTP_ASYNC_SERVICE);
View Full Code Here

Examples of org.apache.http.nio.reactor.ConnectingIOReactor.shutdown()

149
150
151
152
153
154
155
156
157
158
159
            }
        }

        System.out.println("Shutting down I/O reactor");
       
        ioReactor.shutdown();
       
        System.out.println("Done");
    }
   
    static class MyHttpRequestExecutionHandler implements HttpRequestExecutionHandler {
View Full Code Here

Examples of org.apache.http.nio.reactor.IOSession.shutdown()

103
104
105
106
107
108
109
110
111
112
113
            return;
        }
        this.released = true;
        this.reusable = false;
        IOSession iosession = this.entry.getIOSession();
        iosession.shutdown();
        this.manager.releaseConnection(this, this.expiry, this.tunit);
        this.entry = null;
        this.conn = null;
    }
View Full Code Here

Examples of org.apache.http.nio.reactor.ListeningIOReactor.shutdown()

141
142
143
144
145
146
147
148
149
150
151
       
        ListenerEndpoint endpoint = endpoints.iterator().next();
       
        assertEquals(9999, ((InetSocketAddress) endpoint.getAddress()).getPort());
       
        ioreactor.shutdown(1000);
        t.join(1000);
       
        assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus());
    }
View Full Code Here

Examples of org.apache.http.nio.reactor.ssl.SSLIOSession.shutdown()

142
143
144
145
146
147
148
149
150
151
152
        NHttpClientIOTarget conn = createSSLConnection(ssliosession);
        try {
            ssliosession.initialize();
        } catch (SSLException ex) {
            this.handler.exception(conn, ex);
            ssliosession.shutdown();
        }
        return conn;
    }

    @Override
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.