接口 RSocketStrategies.Builder
- 封闭接口:
- RSocketStrategies
public static interface RSocketStrategies.Builder
The builder options for creatingRSocketStrategies.
方法概要
所有方法 实例方法 抽象方法 修饰符和类型 方法 说明 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.
方法详细资料
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.