Package | Description |
---|---|
org.springframework.data.redis.stream |
Modifier and Type | Method and Description |
---|---|
StreamReceiver.StreamReceiverOptionsBuilder<K,V> |
StreamReceiver.StreamReceiverOptionsBuilder.batchSize(int recordsPerPoll)
Configure a batch size for the
COUNT option during reading. |
static StreamReceiver.StreamReceiverOptionsBuilder<String,MapRecord<String,String,String>> |
StreamReceiver.StreamReceiverOptions.builder() |
static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,ObjectRecord<String,T>> |
StreamReceiver.StreamReceiverOptions.builder(HashMapper<T,byte[],byte[]> hashMapper) |
<HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamReceiver.StreamReceiverOptionsBuilder.hashKeySerializer(RedisSerializationContext.SerializationPair<HK> pair)
Configure a hash key serializer.
|
<HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K,HK,HV>> |
StreamReceiver.StreamReceiverOptionsBuilder.hashValueSerializer(RedisSerializationContext.SerializationPair<HV> pair)
Configure a hash value serializer.
|
<NK,NV extends Record<NK,?>> |
StreamReceiver.StreamReceiverOptionsBuilder.keySerializer(RedisSerializationContext.SerializationPair<NK> pair)
Configure a key serializer.
|
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamReceiver.StreamReceiverOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)
Configure a hash mapper.
|
StreamReceiver.StreamReceiverOptionsBuilder<K,V> |
StreamReceiver.StreamReceiverOptionsBuilder.onErrorResume(Function<? super Throwable,? extends org.reactivestreams.Publisher<Void>> resumeFunction)
Configure a resume
Function to resume the main sequence when polling the stream fails. |
StreamReceiver.StreamReceiverOptionsBuilder<K,V> |
StreamReceiver.StreamReceiverOptionsBuilder.pollTimeout(Duration pollTimeout)
Configure a poll timeout for the
BLOCK option during reading. |
<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> |
StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext.SerializationPair<T> pair)
Configure a key, hash key and hash value serializer.
|
<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> |
StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext<T,?> serializationContext)
Configure a key, hash key and hash value serializer.
|
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> |
StreamReceiver.StreamReceiverOptionsBuilder.targetType(Class<NV> targetType)
Configure a hash target type.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.