io.micronaut.configuration.ribbon

Class RibbonRxHttpClient

java.lang.Object

io.micronaut.http.client.DefaultHttpClient

io.micronaut.configuration.ribbon.RibbonRxHttpClient

All Implemented Interfaces:

io.micronaut.context.LifeCycle<io.micronaut.http.client.HttpClient>, io.micronaut.http.client.HttpClient, io.micronaut.http.client.RxHttpClient, io.micronaut.http.client.RxStreamingHttpClient, io.micronaut.http.client.sse.RxSseClient, io.micronaut.http.client.sse.SseClient, io.micronaut.http.client.StreamingHttpClient, io.micronaut.websocket.RxWebSocketClient, io.micronaut.websocket.WebSocketClient, java.io.Closeable, java.lang.AutoCloseable

@Prototype
 @Requires(classes=com.netflix.client.config.IClientConfig.class)
 @Primary
 @Replaces(value=io.micronaut.http.client.DefaultHttpClient.class)
public class RibbonRxHttpClient
extends io.micronaut.http.client.DefaultHttpClient

Extended version of DefaultHttpClient adapted to Ribbon.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.http.client.DefaultHttpClient

io.micronaut.http.client.DefaultHttpClient.HttpClientInitializer, io.micronaut.http.client.DefaultHttpClient.NettyRequestWriter

Field Summary

Fields inherited from class io.micronaut.http.client.DefaultHttpClient

bootstrap, byteBufferFactory, group, HANDLER_AGGREGATOR, HANDLER_CHUNK, HANDLER_CONNECT_TTL, HANDLER_DECODER, HANDLER_STREAM, mediaTypeCodecRegistry

Fields inherited from interface io.micronaut.http.client.HttpClient

DEFAULT_ERROR_TYPE

Constructor Summary

Constructors

Constructor and Description

RibbonRxHttpClient(io.micronaut.http.client.LoadBalancer loadBalancer, io.micronaut.http.client.HttpClientConfiguration configuration, java.lang.String contextPath, io.micronaut.http.client.filter.HttpClientFilterResolver filterResolver, java.util.concurrent.ThreadFactory threadFactory, io.micronaut.http.client.ssl.NettyClientSslBuilder nettyClientSslBuilder, io.micronaut.http.codec.MediaTypeCodecRegistry codecRegistry, java.util.List<RibbonExecutionListenerAdapter> executionListeners) Constructor.

Method Summary

Modifier and Type	Method and Description
protected <O> com.netflix.loadbalancer.reactive.LoadBalancerCommand<O>	buildLoadBalancerCommand() Build the command using the load balancer builder.
protected void	configure(io.micronaut.context.BeanContext beanContext)
<I> io.reactivex.Flowable<io.micronaut.core.io.buffer.ByteBuffer<?>>	dataStream(io.micronaut.http.HttpRequest<I> request)
<I,O,E> io.reactivex.Flowable<io.micronaut.http.HttpResponse<O>>	exchange(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<O> bodyType, io.micronaut.core.type.Argument<E> errorType)
<I> io.reactivex.Flowable<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>>	exchangeStream(io.micronaut.http.HttpRequest<I> request)
java.util.Optional<RibbonLoadBalancer>	getLoadBalancer()
<I,O> io.reactivex.Flowable<O>	jsonStream(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<O> type)

Methods inherited from class io.micronaut.http.client.DefaultHttpClient

applyFilterToResponsePublisher, buildDataStreamPublisher, buildExchangePublisher, buildExchangeStreamPublisher, buildJsonStreamPublisher, buildNettyRequest, buildSslContext, buildStreamExchange, close, closeChannelAsync, configureProxy, configureProxy, connect, connect, createEventLoopGroup, doConnect, doConnect, doConnect, eventStream, eventStream, getConfiguration, getLoadBalancerDiscriminator, getLog, getMediaTypeCodecRegistry, isRunning, jsonStream, jsonStream, resolveRequestURI, resolveRequestURI, setMediaTypeCodecRegistry, start, stop, toBlocking

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.websocket.RxWebSocketClient

connect, connect

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

create

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

exchange, exchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieve, retrieve

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

refresh

Methods inherited from interface io.micronaut.http.client.sse.RxSseClient

eventStream, eventStream, eventStream

Constructor Detail

RibbonRxHttpClient

@Inject
public RibbonRxHttpClient(@Parameter
                                  io.micronaut.http.client.LoadBalancer loadBalancer,
                                  @Parameter
                                  io.micronaut.http.client.HttpClientConfiguration configuration,
                                  @Parameter @Nullable
                                  java.lang.String contextPath,
                                  @Parameter
                                  io.micronaut.http.client.filter.HttpClientFilterResolver filterResolver,
                                  @Named(value="netty") @Nullable
                                  java.util.concurrent.ThreadFactory threadFactory,
                                  io.micronaut.http.client.ssl.NettyClientSslBuilder nettyClientSslBuilder,
                                  io.micronaut.http.codec.MediaTypeCodecRegistry codecRegistry,
                                  java.util.List<RibbonExecutionListenerAdapter> executionListeners)

Constructor.

Parameters:

loadBalancer - loadBalancer

configuration - configuration

contextPath - contextPath

threadFactory - threadFactory

nettyClientSslBuilder - nettyClientSslBuilder

codecRegistry - codecRegistry

executionListeners - executionListeners

Method Detail

configure

@Inject
protected void configure(io.micronaut.context.BeanContext beanContext)

Overrides:

configure in class io.micronaut.http.client.DefaultHttpClient

getLoadBalancer

public java.util.Optional<RibbonLoadBalancer> getLoadBalancer()

Returns:

The RibbonLoadBalancer if one is configured for this client

exchange

public <I,O,E> io.reactivex.Flowable<io.micronaut.http.HttpResponse<O>> exchange(io.micronaut.http.HttpRequest<I> request,
                                                                                 io.micronaut.core.type.Argument<O> bodyType,
                                                                                 io.micronaut.core.type.Argument<E> errorType)

Specified by:

exchange in interface io.micronaut.http.client.HttpClient

Specified by:

exchange in interface io.micronaut.http.client.RxHttpClient

Overrides:

exchange in class io.micronaut.http.client.DefaultHttpClient

exchangeStream

public <I> io.reactivex.Flowable<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>> exchangeStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

exchangeStream in interface io.micronaut.http.client.RxStreamingHttpClient

Specified by:

exchangeStream in interface io.micronaut.http.client.StreamingHttpClient

Overrides:

exchangeStream in class io.micronaut.http.client.DefaultHttpClient

dataStream

public <I> io.reactivex.Flowable<io.micronaut.core.io.buffer.ByteBuffer<?>> dataStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

dataStream in interface io.micronaut.http.client.RxStreamingHttpClient

Specified by:

dataStream in interface io.micronaut.http.client.StreamingHttpClient

Overrides:

dataStream in class io.micronaut.http.client.DefaultHttpClient

jsonStream

public <I,O> io.reactivex.Flowable<O> jsonStream(io.micronaut.http.HttpRequest<I> request,
                                                 io.micronaut.core.type.Argument<O> type)

Specified by:

jsonStream in interface io.micronaut.http.client.RxStreamingHttpClient

Specified by:

jsonStream in interface io.micronaut.http.client.StreamingHttpClient

Overrides:

jsonStream in class io.micronaut.http.client.DefaultHttpClient

buildLoadBalancerCommand

protected <O> com.netflix.loadbalancer.reactive.LoadBalancerCommand<O> buildLoadBalancerCommand()

Build the command using the load balancer builder.

Type Parameters:

O - entity type of the command

Returns:

entity type