Uses of Class
org.springframework.integration.redis.dsl.RedisStreamInboundChannelAdapterSpec

Packages that use RedisStreamInboundChannelAdapterSpec

Package	Description
org.springframework.integration.redis.dsl	Java DSL classes for Redis module.

Uses of RedisStreamInboundChannelAdapterSpec in org.springframework.integration.redis.dsl

Methods in org.springframework.integration.redis.dsl that return RedisStreamInboundChannelAdapterSpec

Modifier and Type	Method	Description
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.autoAck(boolean autoAck)	Specify whether acknowledge message read in the Consumer Group.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.batchSize(int recordsPerPoll)	Specify the batch size for the COUNT option.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.consumerGroup(String consumerGroup)	Specify the name of the consumer group.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.consumerName(@Nullable String consumerName)	Specify the name of the consumer.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.createConsumerGroup(boolean createConsumerGroup)	Specify whether create the consumer group.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.errorResumeFunction(Function<? super Throwable,? extends org.reactivestreams.Publisher<Void>> resumeFunction)	Specify the resume Function when polling the stream fails.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.extractPayload(boolean extractPayload)	Specify whether extract payload.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.objectMapper(HashMapper<?,?,?> hashMapper)	Specify the hashMapper.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.pollTimeout(Duration pollTimeout)	Specify the poll timeout for the BLOCK option.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.readOffset(ReadOffset readOffset)	Specify the offset from which to read message.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.serializer(RedisSerializationContext.SerializationPair<?> pair)	Specify the key, hash key and hash value serializer.
static RedisStreamInboundChannelAdapterSpec	Redis.streamInboundChannelAdapter(ReactiveRedisConnectionFactory connectionFactory, String streamKey)	The factory to produce a RedisStreamInboundChannelAdapterSpec.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.streamReceiverOptions(@Nullable StreamReceiver.StreamReceiverOptions<String,?> streamReceiverOptions)	Specify the streamReceiverOptions to customize the StreamReceiver.
RedisStreamInboundChannelAdapterSpec	RedisStreamInboundChannelAdapterSpec.targetType(Class<?> targetType)	Specify the hash target type.