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(Duration blockTimeout)	Configure how long to wait for a response for an HTTP 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(Duration blockTimeout)

Configure how long to wait for a response for an HTTP service method with a synchronous (blocking) method signature.

By default this is 5 seconds.

Parameters:

blockTimeout - the timeout value

Returns:

this same builder instance

build

public RSocketServiceProxyFactory build()

Build the RSocketServiceProxyFactory instance.