StreamReceiver.StreamReceiverOptions (Spring Data Redis 2.6.0-M3 API)

java.lang.Object
- org.springframework.data.redis.stream.StreamReceiver.StreamReceiverOptions<K,V>

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`static StreamReceiver.StreamReceiverOptionsBuilder<String,MapRecord<String,String,String>>`	`builder()`
`static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,ObjectRecord<String,T>>`	`builder(HashMapper<T,byte[],byte[]> hashMapper)`
`OptionalInt`	`getBatchSize()` Batch size polling using the `COUNT` option during reads.
`RedisSerializationContext.SerializationPair<Object>`	`getHashKeySerializer()`
`HashMapper<Object,Object,Object>`	`getHashMapper()`
`RedisSerializationContext.SerializationPair<Object>`	`getHashValueSerializer()`
`RedisSerializationContext.SerializationPair<K>`	`getKeySerializer()`
`Duration`	`getPollTimeout()` Timeout for blocking polling using the `BLOCK` option during reads.
`HashMapper<Object,Object,Object>`	`getRequiredHashMapper()`
`Function<? super Throwable,? extends org.reactivestreams.Publisher<Void>>`	`getResumeFunction()`
`Class<Object>`	`getTargetType()`
`boolean`	`hasHashMapper()`

public static StreamReceiver.StreamReceiverOptionsBuilder<String,MapRecord<String,String,String>> builder()

public static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,ObjectRecord<String,T>> builder(HashMapper<T,byte[],byte[]> hashMapper)

public Function<? super Throwable,? extends org.reactivestreams.Publisher<Void>> getResumeFunction()

public RedisSerializationContext.SerializationPair<K> getKeySerializer()

public RedisSerializationContext.SerializationPair<Object> getHashKeySerializer()

public RedisSerializationContext.SerializationPair<Object> getHashValueSerializer()

@Nullable
public HashMapper<Object,Object,Object> getHashMapper()

public HashMapper<Object,Object,Object> getRequiredHashMapper()

Class StreamReceiver.StreamReceiverOptions<K,V extends Record<K,?>>