Questions tagged [publish-subscribe]
Publish/subscribe is a messaging pattern where senders (publishers) of messages do not program the messages to be sent directly to specific receivers (subscribers). Rather, published messages are characterized into channels, without knowledge of what, if any, subscribers there may be.
publish-subscribe
2,994
questions
0
votes
1
answer
26
views
Many channels with few publications or few channels with many publications in Redis PubSub?
I am using Redis PubSub for a notification system in an application. I usually have around 1000 concurrent users. For each user I have a personal channel with the user's ID through which several ...
- 816
0
votes
1
answer
16
views
With publishSubscribeChannel, in spring integration, if one subscription fails will the other one still run?
Lets assume that the "throwsException" handler throws an exception. Normally, this will go to the error channel. However, will the second subscription still run? Will the message be sent ...
- 55
0
votes
0
answers
16
views
Sending Message to RabbitMQ using HTTP API
Is there a way to send a message directly in the RabbitMQ publish API with only the message itself?
/api/exchanges/%2f/amq.default/publish
Without putting the message in the payload object and not ...
0
votes
2
answers
52
views
Pub/Sub benchmark: why the benchmark of killing connection each time is better than using single connection
I am a newbie of GCP Pub/Sub, and I try to test the benchmarh of publish message.
we have two scenario below:
both scenario will publish 6 messages.
Scenario 1: create pubsubClient, then publish 6 ...
- 11
1
vote
0
answers
25
views
unsupported pubsub message: "invalidate"
I am trying to receive invalidation message from local redis setup using the client tracking feature in Redis. It basically publishes key that was updated in redis on "__redis__:invalidate" ...
- 11
0
votes
1
answer
33
views
What options do I have to scale out Redis pub/sub?
I am implementing a real-time notification system with websockets and redis pub/sub. Basically, the client connects to the server through websockets and from the backend I subscribe to a specific ...
- 816
1
vote
1
answer
311
views
Can't Enable Pub/Sub Topic For My Project
I have a project created and when I try to enable events (aka a Pub/Sub topic) I just get an error "Could not update project data". I've tried multiple projects and have the same issue.
- 105
0
votes
1
answer
34
views
How do I perform an atomic XREAD and XDEL on a Redis Stream?
I am trying to design a system on Redis, where:
There is a queue of messages
There is a single writer to the queue
There are multiple consumers of "messages" in the queue, each continuously ...
- 4,199
0
votes
1
answer
38
views
It is possible that if a consumer is inactive when a producer sends a message, the consumer can still receive the messages once it active again
In this ActiveMQ Artemis broker.xml once the consumer is not listening while the producer sends the messages to the topic after the while consumer starts listening means the message is gone so I need ...
- 11
0
votes
2
answers
108
views
In-memory data structure or collection in C# that exhibits peek and lock behavior like AWS SQS or Azure Service Bus Queues
I have a requirement to dequeue messages from cloud queue and then process them. However, for each worker instance, we want to let the worker define how many messages it can comfortably process ...
- 447
3
votes
1
answer
74
views
Concurrent HashMap weak consistency missing past keys during iteration - multi thread pub/sub
Noticing weird behavior with ConcurrentHashMap iteration.
Scenario:
Single publisher thread constantly adds new keys to the concurrent hashmap. Note keys are added in sequential order.
Multiple ...
- 31
1
vote
0
answers
37
views
Remote Redis Pub/Sub Partial Base64 encoded Data Flutter
I am trying to do this:
Video=> Python app turns into Frames => publishes it, as base64 encoded frames to Redis => Flutter Subscribes to Redis, Decodes and Shows it.
Testing this with ...
1
vote
1
answer
31
views
How to improve my EventCenter to avoid memory leak?
Question
I Have an Event Center system, but cant automatically remove the event when subscriber be destroyed.
How to improve it?
IEventInfo.cs
public interface IEventInfo { }
public class ...
- 17
0
votes
0
answers
13
views
Is there a pub/sub database that can handle high volume of topics?
I'm looking for a pub/sub database that can handle high volume (hundreds of thousands to millions) of topics/channels where the volume or delivery latency of messages per topic/channel is of lower ...
- 2,517
0
votes
0
answers
25
views
Google Pub Sub working on local, not working on production
I want to develop a system to get notifications for google business review. I set up google business sign in with appropriate scopes. I went through documentation and was able to pull from a ...
