org.springframework.http.client

Class Netty4ClientHttpRequest

java.lang.Object

org.springframework.http.client.AbstractAsyncClientHttpRequest

org.springframework.http.client.Netty4ClientHttpRequest

All Implemented Interfaces:

AsyncClientHttpRequest, ClientHttpRequest, HttpMessage, HttpOutputMessage, HttpRequest

class Netty4ClientHttpRequest
extends AbstractAsyncClientHttpRequest
implements ClientHttpRequest

ClientHttpRequest implementation that uses Netty 4 to execute requests.

Created via the Netty4ClientHttpRequestFactory.

Since:

4.1.2

Author:

Arjen Poutsma, Rossen Stoyanchev

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	Netty4ClientHttpRequest.RequestExecuteHandler A SimpleChannelInboundHandler to update the given SettableListenableFuture.

Field Summary

Fields

Modifier and Type	Field and Description
private ByteBufOutputStream	body
private Bootstrap	bootstrap
private HttpMethod	method
private java.net.URI	uri

Constructor Summary

Constructors

Constructor and Description
Netty4ClientHttpRequest(Bootstrap bootstrap, java.net.URI uri, HttpMethod method)

Method Summary

Modifier and Type	Method and Description
private FullHttpRequest	createFullHttpRequest(HttpHeaders headers)
ClientHttpResponse	execute() Execute this request, resulting in a ClientHttpResponse that can be read.
protected ListenableFuture<ClientHttpResponse>	executeInternal(HttpHeaders headers) Abstract template method that writes the given headers and content to the HTTP request.
protected java.io.OutputStream	getBodyInternal(HttpHeaders headers) Abstract template method that returns the body.
HttpMethod	getMethod() Return the HTTP method of the request.
private static int	getPort(java.net.URI uri)
java.net.URI	getURI() Return the URI of the request.

Methods inherited from class org.springframework.http.client.AbstractAsyncClientHttpRequest

assertNotExecuted, executeAsync, getBody, getHeaders

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.http.HttpOutputMessage

getBody

Methods inherited from interface org.springframework.http.HttpMessage

getHeaders

Field Detail

bootstrap

private final Bootstrap bootstrap

uri

private final java.net.URI uri

method

private final HttpMethod method

body

private final ByteBufOutputStream body

Constructor Detail

Netty4ClientHttpRequest

public Netty4ClientHttpRequest(Bootstrap bootstrap,
                               java.net.URI uri,
                               HttpMethod method)

Method Detail

getMethod

public HttpMethod getMethod()

Description copied from interface: HttpRequest

Return the HTTP method of the request.

Specified by:

getMethod in interface HttpRequest

Returns:

the HTTP method as an HttpMethod enum value, or null if not resolvable (e.g. in case of a non-standard HTTP method)

getURI

public java.net.URI getURI()

Description copied from interface: HttpRequest

Return the URI of the request.

Specified by:

getURI in interface HttpRequest

Returns:

the URI of the request (never null)

getBodyInternal

protected java.io.OutputStream getBodyInternal(HttpHeaders headers)
                                        throws java.io.IOException

Description copied from class: AbstractAsyncClientHttpRequest

Abstract template method that returns the body.

Specified by:

getBodyInternal in class AbstractAsyncClientHttpRequest

Parameters:

headers - the HTTP headers

Returns:

the body output stream

Throws:

java.io.IOException

executeInternal

protected ListenableFuture<ClientHttpResponse> executeInternal(HttpHeaders headers)
                                                        throws java.io.IOException

Description copied from class: AbstractAsyncClientHttpRequest

Abstract template method that writes the given headers and content to the HTTP request.

Specified by:

executeInternal in class AbstractAsyncClientHttpRequest

Parameters:

headers - the HTTP headers

Returns:

the response object for the executed request

Throws:

java.io.IOException

execute

public ClientHttpResponse execute()
                           throws java.io.IOException

Description copied from interface: ClientHttpRequest

Execute this request, resulting in a ClientHttpResponse that can be read.

Specified by:

execute in interface ClientHttpRequest

Returns:

the response result of the execution

Throws:

java.io.IOException - in case of I/O errors

getPort

private static int getPort(java.net.URI uri)

createFullHttpRequest

private FullHttpRequest createFullHttpRequest(HttpHeaders headers)