org.springframework.messaging.rsocket

Interface RSocketStrategies.Builder

All Known Implementing Classes:

DefaultRSocketStrategies.DefaultRSocketStrategiesBuilder

Enclosing interface:

RSocketStrategies

public static interface RSocketStrategies.Builder

The builder options for creating RSocketStrategies.

Method Summary

Modifier and Type	Method and Description
RSocketStrategies	build() Builder the RSocketStrategies instance.
RSocketStrategies.Builder	dataBufferFactory(DataBufferFactory bufferFactory) Configure the DataBufferFactory to use for allocating buffers, for example when preparing requests or when responding.
RSocketStrategies.Builder	decoder(Decoder<?>... decoder) Add decoders for de-serializing Objects.
RSocketStrategies.Builder	decoders(java.util.function.Consumer<java.util.List<Decoder<?>>> consumer) Access and manipulate the list of configured decoders.
RSocketStrategies.Builder	encoder(Encoder<?>... encoder) Add encoders to use for serializing Objects.
RSocketStrategies.Builder	encoders(java.util.function.Consumer<java.util.List<Encoder<?>>> consumer) Access and manipulate the list of configured encoders.
RSocketStrategies.Builder	reactiveAdapterStrategy(ReactiveAdapterRegistry registry) Configure the registry for reactive type support.

Method Detail

encoder

RSocketStrategies.Builder encoder(Encoder<?>... encoder)

Add encoders to use for serializing Objects.

By default this is empty.

decoder

RSocketStrategies.Builder decoder(Decoder<?>... decoder)

Add decoders for de-serializing Objects.

By default this is empty.

encoders

RSocketStrategies.Builder encoders(java.util.function.Consumer<java.util.List<Encoder<?>>> consumer)

Access and manipulate the list of configured encoders.

decoders

RSocketStrategies.Builder decoders(java.util.function.Consumer<java.util.List<Decoder<?>>> consumer)

Access and manipulate the list of configured decoders.

reactiveAdapterStrategy

RSocketStrategies.Builder reactiveAdapterStrategy(ReactiveAdapterRegistry registry)

Configure the registry for reactive type support. This can be used to to adapt to, and/or determine the semantics of a given Publisher.

By default this ReactiveAdapterRegistry.sharedInstance.

Parameters:

registry - the registry to use

dataBufferFactory

RSocketStrategies.Builder dataBufferFactory(DataBufferFactory bufferFactory)

Configure the DataBufferFactory to use for allocating buffers, for example when preparing requests or when responding. The choice here must be aligned with the frame decoder configured in io.rsocket.RSocketFactory.

By default this property is an instance of DefaultDataBufferFactory matching to the default frame decoder in io.rsocket.RSocketFactory which copies the payload. This comes at cost to performance but does not require reference counting and eliminates possibility for memory leaks.

To switch to a zero-copy strategy, configure RSocket accordingly, and then configure this property with an instance of NettyDataBufferFactory with a pooled allocator such as PooledByteBufAllocator#DEFAULT.

Parameters:

bufferFactory - the DataBufferFactory to use

build

RSocketStrategies build()

Builder the RSocketStrategies instance.