I'm creating an user event system using JDK 9 Flow API, so I have a room (which implements Flow.Subscriber<Notification>), it may have many users and each user can offer (dispatch) updates at...

I have a Google Cloud Pub/Sub subscription that is using a dead-letter topic. I recently had an outage that was preventing a number of messages from being processed & they ended up in the dead-...

I have several services in Azure and i would like to sync changes between them using some kind of pub/sub service. I am looking into Redis and Azure Service Bus. The data to be synced is ve...

This great answer on how to implement the traditional observer pattern in Rust concludes with an interesting alternative idea, namely using a broker pattern instead: There are other solutions, suc...

In my project , I've created a simple pub/sub topic with radisson (https://github.com/redisson/redisson) . Publisher will publish some message and there will be multiple subscribers running on diff...

Somebody asked me what PubSub was and how to create a channel (in comment from my answer) and I pointed him to the article on redis.io => http://redis.io/topics/pubsub. I think it is pretty clear, ...

I'm using Pusher (pusher.com) to trigger notification to all logged in clients whenever the admin sends one. For some reason the event is shooting twice, although I only trigger it once. Client s...

I am using publishOn vs subscribeOn both on the same flux as follows: System.out.println("*********Calling Concurrency************"); List<Integer> elements = new ArrayList<>(); Flu...

Quick question: When I pull message from pubsub subscription via command line tool gcloud beta pubsub subscriptions pull MY_SUB I am getting a table with (all details and) data as string (alrea...

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 avai...

I've a use case where the stream should only emit when the cumulative "sum" equals or exceeds a given value, n. Let's take the example of six integers with n = 5. +---+------+---------+ |...

I am trying to write a general purpose wrapper for subscriptions, something like: type Subscriber interface{ Subscribe(addr string) chan interface{} } Suppose there is a library I want to use w...

I'm upgrading a queue processing system that previously used RabbitMQ. I'm currently importing the dead letter and exponential backoff functionality we had in place with RabbitMQ, however I seem to...

Publishing single messages to a RabbitMQ queue can be easily done with the UI, by simply putting the message in the UI and clicking the "Publish Message" button. How do you publish a batch of mess...

Here's my script. #!/usr/bin/env python import traceback import sys import zmq from time import sleep print "Creating the zmq.Context" context = zmq.Context() print "Binding the publisher to t...

I want to stream real-time sensor data(webcam, laser point cloud, etc.) from one robot to multiple observers. In this use case, only the newest data is useful. For example, when a new frame of poin...

I have multiple application instances inside of Amazon EC2, each running several worker processes. What I want is each worker process to be subscribed to some notification(e.g. configuration change...

I would like to subscript to a Salesforce platform event. I am trying to create a client in C#/.NET for a Salesforce Pub/Sub API. There are examples in other languages but not in .NET : https://git...

We are moving from an unstable messaging queue service to Google's Pub Sub in NodeJS. It seems to work well but we would like to include error handling. We would like to limit the number of retrie...

Scenario: Two instances of an application share the same redis instance, but use different databases. The application makes use of the redis pub/sub functions to exchange data between services. Pr...

I followed the Nestjs DOCS regarding pubsub/subsciprtions: According to the examples, pubsub is initialized at the top of a given resolver with: const pubSub = new PubSub(); later the docs say:...

I am new to ROS and rospy, and I am not familiar with non-simple data type as topic. I want to build a ROS node as both a subscriber and publisher: it receives a topic (a list of two float64), and...

What is the difference between the Observer Pattern, Publish/Subscribe, and Data Binding? I searched around a bit on Stack Overflow and did not find any good answers. What I have come to believe ...

I'm creating a small chat application in gRPC right now and I've run into the issue where if a user wants to connect to the gRPC server as a client, I'd like to broadcast that the event has occurre...

I want to set up a network pub/sub event system but also needs to be able to run tasks asynchronously. I have tried getting celery to do the heavy lifting but I feel like I am trying to shim a whol...