How to implement Redis streams with C# Rx
Because I could not find any implementation where we don't use a loop to get the stream content I start to implement one but I'm facing several problems that may some of you can point me to the right place.…
Implement Redis point-to-point queue to guarantee message processing once by any consumer
Redis has very good implementation for PUBSUB where a message published on a channel will be received by multiple receivers registered for the topic. What is the ideal way to implement point-to-point (i.e. queue) semantics where e.g. multiple receivers are…
How to prevent data duplication in redisgraph?
I wrote one code to store graph in redisgraph. Initially it is storing single graph but if I execute the same code second time then it is storing the same graph in database without replacing the previous graph.So, now I…
Spring Boot Redis store a list of POJOs as values
I am using Redis with Spring boot. I am using String as Key and the value against it as a List of complex POJO. Below is my config: @Configuration @EnableCaching @Slf4j public class RedisCacheConfig extends CachingConfigurerSupport { private static final…
SignalR and Redis
I've got a project that uses SignalR and a RedisBackplane, we've moved from StackExchange.Redis to ServiceStack.Redis due to Redis Sentinel compatibility issues (Not movable) However, it now looks like the support for SignalR Redis Backplane seems to be tied into…
Redis don't stop or restart on CentOS7
I've installed Redis version 3.2.12 on one node CentOS 7 of a cluster with Cloudera Manager 6.3 and my redis never stop. Everything is on default, I just added the password, but that has no effects because I can't restart.…
How to switch from hmset() to hset() in Redis?
I get the deprication warning, that Redis.hmset() is deprecated. Use Redis.hset() instead. However hset() takes a third parameter and I can't figure out what name is supposed to be. info = {'users': 10, "timestamp": datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S')} r.hmset("myKey", info) The above…
One Lettuce Redis connection per servlet?
In a servlet, should Lettuce Redis connections be created in init() and shutdown in destroy() or should a connection be created for every request (in doPost or doGet?) I am using sync RedisCommands (connection.sync()) Lettuce states: Lettuce is thread-safe by…
How to delete a redis stream after success processing
I use redis as transport in messenger, I thought that after processing a flow the deletion was automatic but alas not. I do not know how to delete a repeat stream when the processing has been carried out with success.…
How can I use Redisson Write-through caching strategy with an auto-generated PK
I am planning to use Redis with Redisson as a caching layer between my Java app and a PostgreSQL DB. I have a table called Nodes looking like this: CREATE TABLE nodes ( node_id bigint GENERATED BY DEFAULT AS IDENTITY(START…