Interface RSocketStrategies.Builder
- Enclosing interface:
- RSocketStrategies
public static interface RSocketStrategies.Builder
The builder options for creatingRSocketStrategies.
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RSocketStrategiesbuild()Build theRSocketStrategiesinstance.RSocketStrategies.BuilderdataBufferFactory(DataBufferFactory bufferFactory)Configure the DataBufferFactory to use for allocating buffers when preparing requests or creating responses.RSocketStrategies.Builderdecoder(Decoder<?>... decoder)Append to the list of decoders to use for de-serializing Objects from the data or metadata of aPayload.RSocketStrategies.Builderdecoders(Consumer<List<Decoder<?>>> consumer)Apply the consumer to the list of configured decoders, immediately.RSocketStrategies.Builderencoder(Encoder<?>... encoder)Append to the list of encoders to use for serializing Objects to the data or metadata of aPayload.RSocketStrategies.Builderencoders(Consumer<List<Encoder<?>>> consumer)Apply the consumer to the list of configured encoders, immediately.RSocketStrategies.BuildermetadataExtractor(MetadataExtractor metadataExtractor)Configure aMetadataExtractorto extract the route along with other metadata.RSocketStrategies.BuildermetadataExtractorRegistry(Consumer<MetadataExtractorRegistry> consumer)Apply the consumer to theMetadataExtractorRegistryin order to register extra metadata entry extractors.RSocketStrategies.BuilderreactiveAdapterStrategy(ReactiveAdapterRegistry registry)Configure the registry for reactive type support.RSocketStrategies.BuilderrouteMatcher(RouteMatcher routeMatcher)Configure aRouteMatcherfor matching routes to message handlers based on route patterns.
Method Detail
encoder
RSocketStrategies.Builder encoder(Encoder<?>... encoder)
Append to the list of encoders to use for serializing Objects to the data or metadata of aPayload.By default this is initialized with encoders for
String,byte[],ByteBuffer, andDataBuffer.
encoders
RSocketStrategies.Builder encoders(Consumer<List<Encoder<?>>> consumer)
Apply the consumer to the list of configured encoders, immediately.
decoder
RSocketStrategies.Builder decoder(Decoder<?>... decoder)
Append to the list of decoders to use for de-serializing Objects from the data or metadata of aPayload.By default this is initialized with decoders for
String,byte[],ByteBuffer, andDataBuffer.
decoders
RSocketStrategies.Builder decoders(Consumer<List<Decoder<?>>> consumer)
Apply the consumer to the list of configured decoders, immediately.
routeMatcher
RSocketStrategies.Builder routeMatcher(@Nullable RouteMatcher routeMatcher)
Configure aRouteMatcherfor matching routes to message handlers based on route patterns. This option is applicable to client or server responders.By default,
SimpleRouteMatcheris used, backed byAntPathMatcherwith "." as separator. For better efficiency consider switching toPathPatternRouteMatcherfromspring-webinstead.
reactiveAdapterStrategy
RSocketStrategies.Builder reactiveAdapterStrategy(@Nullable ReactiveAdapterRegistry registry)
Configure the registry for reactive type support. This can be used to to adapt to, and/or determine the semantics of a givenPublisher.By default this
ReactiveAdapterRegistry.getSharedInstance().
dataBufferFactory
RSocketStrategies.Builder dataBufferFactory(@Nullable DataBufferFactory bufferFactory)
Configure the DataBufferFactory to use for allocating buffers when preparing requests or creating responses.By default this is set to
NettyDataBufferFactorywith pooled, allocated buffers for zero copy. RSocket must also be configured for zero copy. For client setup,RSocketRequester.Builderadapts automatically to theDataBufferFactoryconfigured here, and sets the frame decoder inRSocketConnectoraccordingly. For server setup, theRSocketServermust be configured accordingly for zero copy too.If using
DefaultDataBufferFactoryinstead, there is no need for related config changes in RSocket.
metadataExtractor
RSocketStrategies.Builder metadataExtractor(@Nullable MetadataExtractor metadataExtractor)
Configure aMetadataExtractorto extract the route along with other metadata. This option is applicable to client or server responders.By default this is
DefaultMetadataExtractorcreated with theconfigureddecoders and extracting a route from"message/x.rsocket.routing.v0"metadata.
metadataExtractorRegistry
RSocketStrategies.Builder metadataExtractorRegistry(Consumer<MetadataExtractorRegistry> consumer)
Apply the consumer to theMetadataExtractorRegistryin order to register extra metadata entry extractors.
build
RSocketStrategies build()
Build theRSocketStrategiesinstance.