Class AbstractReactorHttpExchangeAdapter

java.lang.Object

org.springframework.web.service.invoker.AbstractReactorHttpExchangeAdapter

All Implemented Interfaces:

HttpExchangeAdapter, ReactorHttpExchangeAdapter

Direct Known Subclasses:

WebClientAdapter

public abstract class AbstractReactorHttpExchangeAdapter
extends Object
implements ReactorHttpExchangeAdapter

Convenient base class for a ReactorHttpExchangeAdapter implementation adapting to the synchronous HttpExchangeAdapter contract.

Since:

6.1

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReactorHttpExchangeAdapter()	Protected constructor, for subclasses.

Method Summary

Modifier and Type	Method	Description
void	exchange(HttpRequestValues requestValues)	Perform the given request, and release the response content, if any.
ResponseEntity<Void>	exchangeForBodilessEntity(HttpRequestValues requestValues)	Variant of HttpExchangeAdapter.exchange(HttpRequestValues) with additional access to the response status and headers.
<T> @Nullable T	exchangeForBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Perform the given request and decode the response content to the given type.
<T> ResponseEntity<T>	exchangeForEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Variant of HttpExchangeAdapter.exchangeForBody(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.
HttpHeaders	exchangeForHeaders(HttpRequestValues requestValues)	Perform the given request, release the response content, and return the response headers.
@Nullable Duration	getBlockTimeout()	Return the configured time to block for the response from an HTTP service method with a synchronous (blocking) method signature.
ReactiveAdapterRegistry	getReactiveAdapterRegistry()	Return the configured ReactiveAdapterRegistry.
void	setBlockTimeout(@Nullable Duration blockTimeout)	Configure how long to block for the response of an HTTP service method as described in getBlockTimeout().
void	setReactiveAdapterRegistry(ReactiveAdapterRegistry reactiveAdapterRegistry)	Configure the ReactiveAdapterRegistry to use.

Methods inherited from class Object

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

Methods inherited from interface HttpExchangeAdapter

supportsRequestAttributes

Methods inherited from interface ReactorHttpExchangeAdapter

exchangeForBodilessEntityMono, exchangeForBodyFlux, exchangeForBodyMono, exchangeForEntityFlux, exchangeForEntityMono, exchangeForHeadersMono, exchangeForMono

Constructor Details

AbstractReactorHttpExchangeAdapter

protected AbstractReactorHttpExchangeAdapter()

Protected constructor, for subclasses.

Method Details

setReactiveAdapterRegistry

public void setReactiveAdapterRegistry(ReactiveAdapterRegistry reactiveAdapterRegistry)

Configure the ReactiveAdapterRegistry to use.

By default, this is ReactiveAdapterRegistry.getSharedInstance().

getReactiveAdapterRegistry

public ReactiveAdapterRegistry getReactiveAdapterRegistry()

Description copied from interface: ReactorHttpExchangeAdapter

Return the configured ReactiveAdapterRegistry.

Specified by:

getReactiveAdapterRegistry in interface ReactorHttpExchangeAdapter

setBlockTimeout

public void setBlockTimeout(@Nullable Duration blockTimeout)

Configure how long to block for the response of an HTTP service method as described in getBlockTimeout().

getBlockTimeout

public @Nullable Duration getBlockTimeout()

Description copied from interface: ReactorHttpExchangeAdapter

Return the configured time to block for the response from an HTTP service method with a synchronous (blocking) method signature.

By default, not set in which case the behavior depends on connection and request timeout settings of the underlying HTTP client. We recommend configuring timeout values directly on the underlying HTTP client, which provides more control over such settings.

Specified by:

getBlockTimeout in interface ReactorHttpExchangeAdapter

exchange

public void exchange(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

Perform the given request, and release the response content, if any.

Specified by:

exchange in interface HttpExchangeAdapter

Parameters:

requestValues - the request to perform

exchangeForHeaders

public HttpHeaders exchangeForHeaders(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

Perform the given request, release the response content, and return the response headers.

Specified by:

exchangeForHeaders in interface HttpExchangeAdapter

Parameters:

requestValues - the request to perform

Returns:

the response headers

exchangeForBody

public <T> @Nullable T exchangeForBody(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: HttpExchangeAdapter

Perform the given request and decode the response content to the given type.

Specified by:

exchangeForBody in interface HttpExchangeAdapter

Type Parameters:

T - the type the response is decoded to

Parameters:

requestValues - the request to perform

bodyType - the target type to decode to

Returns:

the decoded response body.

exchangeForBodilessEntity

public ResponseEntity<Void> exchangeForBodilessEntity(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

Variant of HttpExchangeAdapter.exchange(HttpRequestValues) with additional access to the response status and headers.

Specified by:

exchangeForBodilessEntity in interface HttpExchangeAdapter

Returns:

the response entity with status and headers.

exchangeForEntity

public <T> ResponseEntity<T> exchangeForEntity(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: HttpExchangeAdapter

Variant of HttpExchangeAdapter.exchangeForBody(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.

Specified by:

exchangeForEntity in interface HttpExchangeAdapter

Returns:

the response entity with status, headers, and body.