Questions tagged [spring-data-redis-reactive]
29 questions
7
votes
4 answers
How to continuosly listen on redis stream using lettuce java library
I am trying to listen on a redis stream and process the message as and when they arrive. I am using async command and I expect the message to be pushed instead of being pulled. So I don't think a while loop is required. But the following code seems…
falcon
- 1,332
- 20
- 39
4
votes
4 answers
Unable to connect to Redis; nested exception is io.lettuce.core.RedisConnectionException using ReactiveRedisTemplate
I am new to Reactive Programming. i need to connect to Redis to save and get some data. The redis instance is present in cloud.
Am using Lettuce Connection factory to establish the connection.
when establishing the connection to redis, the request…
Urandoor Shilpa
- 61
- 1
- 1
- 9
4
votes
0 answers
Spring data redis stream receiver completes prematurely
I am using Spring data Redis to consume from a Redis stream ,using the reactive stream receiver to listen over a consumer group works ,but have observed that the Flux stream closes prematurely sometimes and doesn't listen to new messages any more…
Gaurav Rawat
- 1,294
- 1
- 25
- 52
3
votes
2 answers
Usage of elapsed() function work on Mono?
I am trying to get execution time for reading from redis in reactive programming, on looking up docs I am able to see that elapsed() method will does the same and implemented code as below.
Flux.fromIterable(getActions(httpHeaders))
…
akreddy.21
- 626
- 3
- 8
- 21
2
votes
0 answers
Spring actuator error out the heath check during the startup : RedisReactiveHealthIndicator : Redis health check failed
We are seeing the below error after the spring boot upgrade to 2.2.11.RELEASE. I think the first health check if failing with the below error but when I invoke the health endpoint i see that health check is success.
2020-12-28 05:42:08.840 WARN 1…
Vivekanad Y
- 21
- 3
2
votes
0 answers
Correct way to store list of objects in Spring Data Redis Reactive
I need to store a list of object in Redis. Every element of the list should be accessed for a unique key. For that I think that the list of object should be stored as a map of object in Redis (I converted to String before to store it):
{
…
Cesar Miguel
- 661
- 1
- 13
- 38
2
votes
0 answers
Spring WebSession Redis Exception
I want to store my WebSession in Redis. There is no problem at put operation, but it throws exception when retrieving stored record. Here is my example stack trace
Caused by:
com.fasterxml.jackson.databind.exc.MismatchedInputException:
Unexpected…
denizg
- 828
- 9
- 18
2
votes
1 answer
Strange behavior with SSE endpoint using Redis
I need to push some data to the client if it is in Redis, but client keeps reconnecting to the SSE endpoint every 5 seconds.
The backend code:
@RestController
@RequestMapping("/reactive-task")
public class TaskRedisController {
private final…
Magzhan Z
- 25
- 5
1
vote
0 answers
Redis Pipeline using spring data redis reactive
Pipeline support is available on RedisTemplate (RedisTemplate.executePipelined) But I couldn't find any equivalent option in ReactiveRedisTemplate to use pipeline or batch operations.
Kindly direct me to the right API or any alternative…
user1433374
- 185
- 1
- 9
1
vote
2 answers
How to create Empty redis stream?
Is possible to create empty stream using spring redis data?
Am trying to create rest endpoint to create just stream without data.
Thanks,
Aswath Murugan
- 505
- 2
- 4
- 12
1
vote
0 answers
ReactiveRedisTemplate List Operations - set Expire and TTL
This integration test uses ReactiveRedisTemplate list operations to:
push a List to the cache using the ReactiveRedisTemplate
list operation leftPushAll()
retrieves the List as a flux from the
cache using the ReactiveRedisTemplate list operation…
user619804
- 2,286
- 12
- 46
- 71
1
vote
1 answer
Spring Data Reactive Hash Redis Template for Custom Objects
I've been triyng to use the Jackson2JsonRedisSerializer to serialize a custom instance as the hash value in a Redis store. It seems that even though I have correctly created the template, no hash is created.
Just a note that I'm using…
codeninja55
- 49
- 5
1
vote
2 answers
Is there a way to set a timeout in Java with Redis reactive?
I'm using ReactiveRedisConnection to configure a connection to a local redis container.
But in the future the application will be hosted on a webserver and the redis on a different server.
Is there any option to set a timeout for a request?
Johnnes Souza
- 361
- 1
- 8
- 22
0
votes
0 answers
How to use Redis cache to cache the Object using spring boot webflux framework having mongodb as datasource
I tried using @cachable annotation and getting error as can't serialize Mono
Teegen
- 3
- 3
0
votes
0 answers
Spring Data Redis Operation key type
Good evening! I want to create ReactiveRedisOperations with keys of type Long, but i cannot fing Long deserializer for that.
@Configuration
class RedisConfiguration {
@Bean
fun reactiveRedisOperations(factory:…
Алексей Горчаков
- 1
- 1