Package org.springframework.messaging.rsocket.service

Class RSocketServiceProxyFactory.Builder

java.lang.Object

org.springframework.messaging.rsocket.service.RSocketServiceProxyFactory.Builder

Enclosing class:

RSocketServiceProxyFactory

public static final class RSocketServiceProxyFactory.Builder
extends Object

Builder to create an RSocketServiceProxyFactory.

Method Summary

Modifier and Type	Method	Description
RSocketServiceProxyFactory.Builder	blockTimeout(@Nullable Duration blockTimeout)	Configure how long to block for the response of an RSocket service method with a synchronous (blocking) method signature.
RSocketServiceProxyFactory	build()	Build the RSocketServiceProxyFactory instance.
RSocketServiceProxyFactory.Builder	customArgumentResolver(RSocketServiceArgumentResolver resolver)	Register a custom argument resolver, invoked ahead of default resolvers.
RSocketServiceProxyFactory.Builder	embeddedValueResolver(StringValueResolver resolver)	Set the StringValueResolver to use for resolving placeholders and expressions embedded in RSocketExchange.value().
RSocketServiceProxyFactory.Builder	reactiveAdapterRegistry(ReactiveAdapterRegistry registry)	Set the ReactiveAdapterRegistry to use to support different asynchronous types for HTTP service method return values.
RSocketServiceProxyFactory.Builder	rsocketRequester(RSocketRequester requester)	Provide the requester to perform requests through.

Methods inherited from class java.lang.Object

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

Method Details

rsocketRequester

public RSocketServiceProxyFactory.Builder rsocketRequester(RSocketRequester requester)

Provide the requester to perform requests through.

Parameters:

requester - the requester to use

Returns:

the same builder instance

customArgumentResolver

public RSocketServiceProxyFactory.Builder customArgumentResolver(RSocketServiceArgumentResolver resolver)

Register a custom argument resolver, invoked ahead of default resolvers.

Parameters:

resolver - the resolver to add

Returns:

the same builder instance

embeddedValueResolver

public RSocketServiceProxyFactory.Builder embeddedValueResolver(StringValueResolver resolver)

Set the StringValueResolver to use for resolving placeholders and expressions embedded in RSocketExchange.value().

Parameters:

resolver - the resolver to use

Returns:

this same builder instance

reactiveAdapterRegistry

public RSocketServiceProxyFactory.Builder reactiveAdapterRegistry(ReactiveAdapterRegistry registry)

Set the ReactiveAdapterRegistry to use to support different asynchronous types for HTTP service method return values.

By default this is ReactiveAdapterRegistry.getSharedInstance().

Returns:

this same builder instance

blockTimeout

public RSocketServiceProxyFactory.Builder blockTimeout(@Nullable Duration blockTimeout)

Configure how long to block for the response of an RSocket service method with a synchronous (blocking) method signature.

By default this is not set, in which case the behavior depends on connection and response timeout settings of the underlying RSocket ClientTransport as well as RSocket keep-alive settings. We recommend configuring timeout values at the RSocket level which provides more control.

Parameters:

blockTimeout - the timeout value

Returns:

this same builder instance

build

public RSocketServiceProxyFactory build()

Build the RSocketServiceProxyFactory instance.