I have an issue where, if I subscribe multiple times to the same Redis channel, my subscribers start receiving duplicate messages. Here is my subscription method: public void SubscribeToUserNotifications(string userId, Action<string?> onMessage) { _subscriber.Subscribe ( new RedisChannel($"orders:notifications:user:{userId}", RedisChannel.PatternMode.Literal), (channel, message)…
I want to use Dapr to subscribe to changes in an Azure App Configuration store as documented on this page: https://docs.dapr.io/reference/components-reference/supported-configuration-stores/azure-appconfig-configuration-store/ When I run my application I succesfully read the configuration from the Azure App Configuration store, however I do…
Given the following scenario: One EC2 instance containing an app A, that acts as publisher. N EC2 instances containing an app B, that acts as subscriber. and Both apps A and B cannot be exposed on the Internet (internal). Apps…
I have this configuration for my pub/sub implementation: @Bean public RedisMessageListenerContainer container(LettuceConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.addMessageListener(listenerAdapter, new ChannelTopic(publishChannel)); return container; } @Bean public MessageListenerAdapter listenerAdapter(RedisReceiver receiver) { return new MessageListenerAdapter(receiver, "receiveMessage"); } @Bean…
This is my code and "print("run to onReceive (text)")" run twice when text change (like a image). Why? and thank you! import SwiftUI class ContentViewViewModel : ObservableObject { @Published var text = "" } struct ContentView: View { @StateObject private…
I want to create a realtime api. Github Link of current code There will be two types of users A and B. Users A can connect to the service using a websocket to see realtime Updates. Users B can only…
I am developing a private chat for two or more users to communicate with each other. I have an endpoint for the websocket connection where only authenticated users are able to do a handshake between client and the server The…
I am currently implementing redis PUB/SUB in one of my project, and it raises a concern to me, what's the size limitation of a message when PUB/SUB in Redis channel. Was the limit equal to the available memory of the…
I like to do an SSE with the response of redis.subscribe in quarkus. I have a sample from the quarkus-quickstart for a simple SSE @GET @Produces(MediaType.SERVER_SENT_EVENTS) @SseElementType(MediaType.TEXT_PLAIN) @Path("{name}/streaming") public Multi<String> greeting(@org.jboss.resteasy.annotations.jaxrs.PathParam String name) { return Multi.createFrom().publisher(vertx.periodicStream(2000).toMulti()) .map(l -> String.format("Hello %s!…
Requirement A system undergoes some state change, and multiple other parts of the system has to know this(lets call them observers) so that they can perform some actions based on the current state, the actions of the observers are important,…