Package org.xbib.netty.http.client

Class Client

java.lang.Object

org.xbib.netty.http.client.Client

public final class Client
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Client.TransportListener

Constructor Summary

Constructors

Constructor and Description
Client()
Client(ClientConfig clientConfig)
Client(ClientConfig clientConfig, io.netty.buffer.ByteBufAllocator byteBufAllocator, io.netty.channel.EventLoopGroup eventLoopGroup, java.lang.Class<? extends io.netty.channel.socket.SocketChannel> socketChannelClass)

Method Summary

Modifier and Type	Method and Description
static ClientBuilder	builder()
void	close()
void	close(Transport transport)
void	continuation(Transport transport, Request request) For following redirects, construct a new transport.
Transport	execute(Request request)
<T> java.util.concurrent.CompletableFuture<T>	execute(Request request, java.util.function.Function<io.netty.handler.codec.http.FullHttpResponse,T> supplier)
io.netty.buffer.ByteBufAllocator	getByteBufAllocator()
ClientConfig	getClientConfig()
io.netty.channel.EventLoopGroup	getEventLoopGroup()
BoundedChannelPool<HttpAddress>	getPool()
boolean	hasPooledConnections()
void	logDiagnostics(java.util.logging.Level level)
io.netty.channel.Channel	newChannel()
io.netty.channel.Channel	newChannel(HttpAddress httpAddress)
Transport	newTransport()
Transport	newTransport(HttpAddress httpAddress)
Transport	newTransport(org.xbib.net.URL url, io.netty.handler.codec.http.HttpVersion httpVersion)
Transport	pooledExecute(Request request)
Transport	prepareRequest(Request request)
void	releaseChannel(io.netty.channel.Channel channel)
void	retry(Transport transport, Request request) Retry request by following a back-off strategy.
void	setTransportListener(Client.TransportListener transportListener)
void	shutdown()
void	shutdownGracefully()

Methods inherited from class java.lang.Object

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

Constructor Detail

Client

public Client()

Client

public Client(ClientConfig clientConfig)

Client

public Client(ClientConfig clientConfig,
              io.netty.buffer.ByteBufAllocator byteBufAllocator,
              io.netty.channel.EventLoopGroup eventLoopGroup,
              java.lang.Class<? extends io.netty.channel.socket.SocketChannel> socketChannelClass)

Method Detail

builder

public static ClientBuilder builder()

getClientConfig

public ClientConfig getClientConfig()

getByteBufAllocator

public io.netty.buffer.ByteBufAllocator getByteBufAllocator()

getEventLoopGroup

public io.netty.channel.EventLoopGroup getEventLoopGroup()

setTransportListener

public void setTransportListener(Client.TransportListener transportListener)

hasPooledConnections

public boolean hasPooledConnections()

getPool

public BoundedChannelPool<HttpAddress> getPool()

logDiagnostics

public void logDiagnostics(java.util.logging.Level level)

newTransport

public Transport newTransport()

newTransport

public Transport newTransport(org.xbib.net.URL url,
                              io.netty.handler.codec.http.HttpVersion httpVersion)

newTransport

public Transport newTransport(HttpAddress httpAddress)

newChannel

public io.netty.channel.Channel newChannel(HttpAddress httpAddress)
                                    throws java.io.IOException

Throws:

java.io.IOException

newChannel

public io.netty.channel.Channel newChannel()
                                    throws java.io.IOException

Throws:

java.io.IOException

releaseChannel

public void releaseChannel(io.netty.channel.Channel channel)
                    throws java.io.IOException

Throws:

java.io.IOException

execute

public Transport execute(Request request)
                  throws java.io.IOException

Throws:

java.io.IOException

execute

public <T> java.util.concurrent.CompletableFuture<T> execute(Request request,
                                                             java.util.function.Function<io.netty.handler.codec.http.FullHttpResponse,T> supplier)
                                                      throws java.io.IOException

Throws:

java.io.IOException

pooledExecute

public Transport pooledExecute(Request request)
                        throws java.io.IOException

Throws:

java.io.IOException

continuation

public void continuation(Transport transport,
                         Request request)
                  throws java.io.IOException

For following redirects, construct a new transport.

Parameters:

transport - the previous transport

request - the new request for continuing the request.

Throws:

java.io.IOException

retry

public void retry(Transport transport,
                  Request request)
           throws java.io.IOException

Retry request by following a back-off strategy.

Parameters:

transport - the transport to retry

request - the request to retry

Throws:

java.io.IOException - if retry failed

prepareRequest

public Transport prepareRequest(Request request)

close

public void close(Transport transport)
           throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

shutdownGracefully

public void shutdownGracefully()
                        throws java.io.IOException

Throws:

java.io.IOException

shutdown

public void shutdown()