Package org.apache.http.nio.conn

Examples of org.apache.http.nio.conn.ManagedClientAsyncConnection

177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
    public void close() {
        if (this.closed) {
            return;
        }
        this.closed = true;
        ManagedClientAsyncConnection localConn = this.managedConn;
        if (localConn != null) {
            if (this.log.isDebugEnabled()) {
                this.log.debug("[exchange: " + this.id + "] aborting connection " + localConn);
            }
            try {
                localConn.abortConnection();
            } catch (IOException ioex) {
                this.log.debug("I/O error releasing connection", ioex);
            }
        }
        try {
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
    public void close() {
        if (this.closed) {
            return;
        }
        this.closed = true;
        final ManagedClientAsyncConnection localConn = this.managedConn;
        if (localConn != null) {
            if (this.log.isDebugEnabled()) {
                this.log.debug("[exchange: " + this.id + "] aborting connection " + localConn);
            }
            try {
                localConn.abortConnection();
            } catch (final IOException ioex) {
                this.log.debug("I/O error releasing connection", ioex);
            }
        }
        try {
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
        public void completed(final HttpPoolEntry entry) {
            if (log.isDebugEnabled()) {
                log.debug("Connection leased: " + format(entry) + formatStats(entry.getRoute()));
            }
            ManagedClientAsyncConnection conn = new ManagedClientAsyncConnectionImpl(
                    PoolingClientAsyncConnectionManager.this,
                    PoolingClientAsyncConnectionManager.this.connFactory,
                    entry);
            if (!this.future.completed(conn)) {
                pool.release(entry, true);
View Full Code Here
250
251
252
253
254
255
256
257
258
259
260
261
262
                                    decoder.read(buf);
                                }

                                @Override
                                protected Object buildResult(final HttpContext context) throws Exception {
                                    ManagedClientAsyncConnection conn = (ManagedClientAsyncConnection) context.getAttribute(
                                            IOEventDispatch.CONNECTION_KEY);
                                    return conn.getState();
                                }

                                @Override
                                protected void releaseResources() {
                                }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
    public void close() {
        if (this.closed) {
            return;
        }
        this.closed = true;
        final ManagedClientAsyncConnection localConn = this.managedConn;
        if (localConn != null) {
            if (this.log.isDebugEnabled()) {
                this.log.debug("[exchange: " + this.id + "] aborting connection " + localConn);
            }
            try {
                localConn.abortConnection();
            } catch (final IOException ioex) {
                this.log.debug("I/O error releasing connection", ioex);
            }
        }
        try {
View Full Code Here
282
283
284
285
286
287
288
289
290
291
292
        public void completed(final HttpPoolEntry entry) {
            if (log.isDebugEnabled()) {
                log.debug("Connection leased: " + format(entry) + formatStats(entry.getRoute()));
            }
            final ManagedClientAsyncConnection conn = new ManagedClientAsyncConnectionImpl(
                    PoolingClientAsyncConnectionManager.this,
                    PoolingClientAsyncConnectionManager.this.connFactory,
                    entry);
            if (!this.future.completed(conn)) {
                pool.release(entry, true);
View Full Code Here
294
295
296
297
298
299
300
301
302
303
304
        public void completed(final HttpPoolEntry entry) {
            if (log.isDebugEnabled()) {
                log.debug("Connection leased: " + format(entry) + formatStats(entry.getRoute()));
            }
            ManagedClientAsyncConnection conn = new ManagedClientAsyncConnectionImpl(
                    PoolingClientAsyncConnectionManager.this,
                    PoolingClientAsyncConnectionManager.this.connFactory,
                    entry);
            if (!this.future.completed(conn)) {
                pool.release(entry, true);
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
    public void close() {
        if (this.closed) {
            return;
        }
        this.closed = true;
        ManagedClientAsyncConnection localConn = this.managedConn;
        if (localConn != null) {
            if (this.log.isDebugEnabled()) {
                this.log.debug("[exchange: " + this.id + "] aborting connection " + localConn);
            }
            try {
                localConn.abortConnection();
            } catch (IOException ioex) {
                this.log.debug("I/O error releasing connection", ioex);
            }
        }
        try {
View Full Code Here
250
251
252
253
254
255
256
257
258
259
260
261
262
                                    decoder.read(buf);
                                }

                                @Override
                                protected Object buildResult(final HttpContext context) throws Exception {
                                    ManagedClientAsyncConnection conn = (ManagedClientAsyncConnection) context.getAttribute(
                                            IOEventDispatch.CONNECTION_KEY);
                                    return conn.getState();
                                }

                                @Override
                                protected void releaseResources() {
                                }
View Full Code Here
TOP

Related Classes of org.apache.http.nio.conn.ManagedClientAsyncConnection

  • org.apache.http.impl.nio.client.DefaultAsyncRequestDirector
  • org.apache.http.impl.nio.client.TestStatefulConnManagement$HttpWorker
  • org.apache.http.impl.nio.conn.PoolingClientAsyncConnectionManager$InternalPoolEntryCallback
  • org.apache.http.nio.client.integration.TestStatefulConnManagement$HttpWorker
    • 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.