/*
 * ====================================================================
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of the Apache Software Foundation.  For more
 * information on the Apache Software Foundation, please see
 * <http://www.apache.org/>.
 *
 */
package org.apache.http.impl.nio.pool;

import java.io.IOException;

import javax.net.ssl.SSLContext;

import org.apache.http.HttpHost;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.apache.http.HttpResponseFactory;
import org.apache.http.annotation.ThreadingBehavior;
import org.apache.http.annotation.Contract;
import org.apache.http.config.ConnectionConfig;
import org.apache.http.impl.DefaultHttpResponseFactory;
import org.apache.http.impl.nio.DefaultNHttpClientConnectionFactory;
import org.apache.http.impl.nio.SSLNHttpClientConnectionFactory;
import org.apache.http.nio.NHttpClientConnection;
import org.apache.http.nio.NHttpConnectionFactory;
import org.apache.http.nio.NHttpMessageParserFactory;
import org.apache.http.nio.NHttpMessageWriterFactory;
import org.apache.http.nio.pool.NIOConnFactory;
import org.apache.http.nio.reactor.IOEventDispatch;
import org.apache.http.nio.reactor.IOSession;
import org.apache.http.nio.reactor.ssl.SSLSetupHandler;
import org.apache.http.nio.util.ByteBufferAllocator;
import org.apache.http.nio.util.HeapByteBufferAllocator;
import org.apache.http.params.HttpParams;
import org.apache.http.util.Args;

A basic NIOConnFactory implementation that creates NHttpClientConnection instances given a HttpHost instance.
Since:4.2
/** * A basic {@link NIOConnFactory} implementation that creates * {@link NHttpClientConnection} instances given a {@link HttpHost} instance. * * @since 4.2 */
@SuppressWarnings("deprecation") @Contract(threading = ThreadingBehavior.IMMUTABLE_CONDITIONAL) public class BasicNIOConnFactory implements NIOConnFactory<HttpHost, NHttpClientConnection> { private final NHttpConnectionFactory<? extends NHttpClientConnection> plainFactory; private final NHttpConnectionFactory<? extends NHttpClientConnection> sslFactory; public BasicNIOConnFactory( final NHttpConnectionFactory<? extends NHttpClientConnection> plainFactory, final NHttpConnectionFactory<? extends NHttpClientConnection> sslFactory) { super(); Args.notNull(plainFactory, "Plain HTTP client connection factory"); this.plainFactory = plainFactory; this.sslFactory = sslFactory; } public BasicNIOConnFactory( final NHttpConnectionFactory<? extends NHttpClientConnection> plainFactory) { this(plainFactory, null); }
Deprecated:(4.3) use BasicNIOConnFactory(SSLContext, SSLSetupHandler, NHttpMessageParserFactory<HttpResponse>, NHttpMessageWriterFactory<HttpRequest>, ByteBufferAllocator, ConnectionConfig)
/** * @deprecated (4.3) use {@link BasicNIOConnFactory#BasicNIOConnFactory(SSLContext, * SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory, * ByteBufferAllocator, ConnectionConfig)} */
@Deprecated public BasicNIOConnFactory( final SSLContext sslContext, final SSLSetupHandler sslHandler, final HttpResponseFactory responseFactory, final ByteBufferAllocator allocator, final HttpParams params) { this(new DefaultNHttpClientConnectionFactory( responseFactory, allocator, params), new SSLNHttpClientConnectionFactory( sslContext, sslHandler, responseFactory, allocator, params)); }
Deprecated:(4.3) use BasicNIOConnFactory(SSLContext, SSLSetupHandler, ConnectionConfig)
/** * @deprecated (4.3) use {@link BasicNIOConnFactory#BasicNIOConnFactory(SSLContext, * SSLSetupHandler, ConnectionConfig)} */
@Deprecated public BasicNIOConnFactory( final SSLContext sslContext, final SSLSetupHandler sslHandler, final HttpParams params) { this(sslContext, sslHandler, DefaultHttpResponseFactory.INSTANCE, HeapByteBufferAllocator.INSTANCE, params); }
Deprecated:(4.3) use BasicNIOConnFactory(ConnectionConfig)
/** * @deprecated (4.3) use {@link BasicNIOConnFactory#BasicNIOConnFactory(ConnectionConfig)} */
@Deprecated public BasicNIOConnFactory(final HttpParams params) { this(null, null, params); }
Since:4.3
/** * @since 4.3 */
public BasicNIOConnFactory( final SSLContext sslContext, final SSLSetupHandler sslHandler, final NHttpMessageParserFactory<HttpResponse> responseParserFactory, final NHttpMessageWriterFactory<HttpRequest> requestWriterFactory, final ByteBufferAllocator allocator, final ConnectionConfig config) { this(new DefaultNHttpClientConnectionFactory( responseParserFactory, requestWriterFactory, allocator, config), new SSLNHttpClientConnectionFactory( sslContext, sslHandler, responseParserFactory, requestWriterFactory, allocator, config)); }
Since:4.3
/** * @since 4.3 */
public BasicNIOConnFactory( final SSLContext sslContext, final SSLSetupHandler sslHandler, final ConnectionConfig config) { this(sslContext, sslHandler, null, null, null, config); }
Since:4.3
/** * @since 4.3 */
public BasicNIOConnFactory(final ConnectionConfig config) { this(new DefaultNHttpClientConnectionFactory(config), null); } @Override public NHttpClientConnection create(final HttpHost route, final IOSession session) throws IOException { final NHttpClientConnection conn; if (route.getSchemeName().equalsIgnoreCase("https")) { if (this.sslFactory == null) { throw new IOException("SSL not supported"); } conn = this.sslFactory.createConnection(session); } else { conn = this.plainFactory.createConnection(session); } session.setAttribute(IOEventDispatch.CONNECTION_KEY, conn); return conn; } }