io.micronaut.http.client.netty

Class RxNettyHttpClientRegistry

java.lang.Object

io.micronaut.http.client.netty.RxNettyHttpClientRegistry

All Implemented Interfaces:

RxHttpClientRegistry, java.lang.AutoCloseable

@Factory
 @Internal
public class RxNettyHttpClientRegistry
extends java.lang.Object
implements java.lang.AutoCloseable, RxHttpClientRegistry

Factory for the default implementation of the HttpClient interface based on Netty.

Since:

2.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description

RxNettyHttpClientRegistry(HttpClientConfiguration defaultHttpClientConfiguration, HttpClientFilterResolver httpClientFilterResolver, LoadBalancerResolver loadBalancerResolver, NettyClientSslBuilder nettyClientSslBuilder, java.util.concurrent.ThreadFactory threadFactory, MediaTypeCodecRegistry codecRegistry, EventLoopGroupRegistry eventLoopGroupRegistry, EventLoopGroupFactory eventLoopGroupFactory, BeanContext beanContext, java.util.List<InvocationInstrumenterFactory> invocationInstrumenterFactories) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
void	disposeClient(AnnotationMetadata annotationMetadata) Dispose of the client defined by the given metadata.
DefaultHttpClient	getClient(AnnotationMetadata metadata) Return the client for the given annotation metadata.
RxHttpClient	getClient(HttpVersion httpVersion, java.lang.String clientId, java.lang.String path) Return the client for the client ID and path.
protected DefaultHttpClient	httpClient(InjectionPoint<?> injectionPoint, LoadBalancer loadBalancer, HttpClientConfiguration configuration, BeanContext beanContext) Creates a new HttpClient for the given injection point.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.http.client.RxHttpClientRegistry

getDefaultClient

Constructor Detail

RxNettyHttpClientRegistry

public RxNettyHttpClientRegistry(HttpClientConfiguration defaultHttpClientConfiguration,
                                 HttpClientFilterResolver httpClientFilterResolver,
                                 LoadBalancerResolver loadBalancerResolver,
                                 NettyClientSslBuilder nettyClientSslBuilder,
                                 java.util.concurrent.ThreadFactory threadFactory,
                                 MediaTypeCodecRegistry codecRegistry,
                                 EventLoopGroupRegistry eventLoopGroupRegistry,
                                 EventLoopGroupFactory eventLoopGroupFactory,
                                 BeanContext beanContext,
                                 java.util.List<InvocationInstrumenterFactory> invocationInstrumenterFactories)

Default constructor.

Parameters:

defaultHttpClientConfiguration - The default HTTP client configuration

httpClientFilterResolver - The HTTP client filter resolver

loadBalancerResolver - The load balancer resolver

nettyClientSslBuilder - The client SSL builder

threadFactory - The thread factory

codecRegistry - The codec registry

eventLoopGroupRegistry - The event loop group registry

eventLoopGroupFactory - The event loop group factory

beanContext - The bean context

invocationInstrumenterFactories - The invocation instrumenter factories

Method Detail

getClient

@NonNull
public RxHttpClient getClient(HttpVersion httpVersion,
                                       @NonNull
                                       java.lang.String clientId,
                                       @Nullable
                                       java.lang.String path)

Description copied from interface: RxHttpClientRegistry

Return the client for the client ID and path.

Specified by:

getClient in interface RxHttpClientRegistry

Parameters:

httpVersion - The HTTP version

clientId - The client ID

path - The path (Optional)

Returns:

The client

getClient

@NonNull
public DefaultHttpClient getClient(@NonNull
                                            AnnotationMetadata metadata)

Description copied from interface: RxHttpClientRegistry

Return the client for the given annotation metadata.

Specified by:

getClient in interface RxHttpClientRegistry

Parameters:

metadata - The annotation metadata.

Returns:

The client

close

@PreDestroy
public void close()

Specified by:

close in interface java.lang.AutoCloseable

disposeClient

public void disposeClient(AnnotationMetadata annotationMetadata)

Description copied from interface: RxHttpClientRegistry

Dispose of the client defined by the given metadata.

Specified by:

disposeClient in interface RxHttpClientRegistry

Parameters:

annotationMetadata - The annotation metadata

httpClient

@Bean
 @Primary
protected DefaultHttpClient httpClient(@Nullable
                                                       InjectionPoint<?> injectionPoint,
                                                       @Parameter @Nullable
                                                       LoadBalancer loadBalancer,
                                                       @Parameter @Nullable
                                                       HttpClientConfiguration configuration,
                                                       BeanContext beanContext)

Creates a new HttpClient for the given injection point.

Parameters:

injectionPoint - The injection point

loadBalancer - The load balancer to use (Optional)

configuration - The configuration (Optional)

beanContext - The bean context to use

Returns:

The client