Im trying to create a new message queue which would send a message to external system but im not able to trigger the new custom event. From the docs ive seen we need to use .addevent() method but ...

I'm building a distributed system that processes messages from hundreds of thousands of sensors, each identified by a sensor_id. I need to guarantee: Strict ordering per sensor_id No two consumers ...

I’m building a chat app using Node.js, Express, MongoDB, and Socket.io. Right now, I load all conversations (around 1,000+) at once, and it’s making the app slow. I want to add pagination to the ...

I've been asked to evaluate RabbitMQ instead of Kafka but found it hard to find a situation where a message queue is more suitable than Kafka. Does anyone know use cases where a message queue fits ...

In Symfony I use a custom Serializer upon a transport: framework: messenger: transports: async: '%env(MESSENGER_TRANSPORT_DSN)%' failed: 'doctrine://default?...

The existing examples of the multiprocessing-module assume, the tasks are independent, but my situation is "hairier". I need to process several hundred thousands of widgets. These are ...

I’m trying to configure scheduled redelivery in MassTransit when using Kafka as the transport. Immediate retries work fine using UseMessageRetry. Since Kafka does not support delayed redelivery, I’m ...

I’m working on an Azure Functions project using the new Flex Consumption model with @azure/functions in TypeScript. I have two functions: Producer – sends a message to a storage queue: export async ...

I am making a Win32 app. In this, there are two windows - the top one is transparent, and the bottom one is normal. I am trying to achieve this effect: When the click happens on the top transparent ...

I'm learning the messaging system and got confused by those terminology. All the messaging system below provides loose coupling between services with different sets of features. queue - FIFO, ...

We'd be interested to hear any experiences with the pros and cons of ActiveMQ vs RabbitMQ vs ZeroMQ. Information about any other interesting message queues is also welcome.

Trying to start Celery first time but issues error as below, i have installed redis and its starting fine , but still somehow django seems to have issues with it , File "<frozen importlib....

I’ve created a service in NestJS and connected it to RabbitMQ. The connection is established successfully, but I don’t receive any messages unless I manually add a binding in the RabbitMQ Management ...

I'm building a website that lets users add new items in their profiles. Users can also do the same using Discord bot's commands. In both cases the Discord bot sends a message New item added by @user ...

I’m working with BullMQ (v5+) and need to implement a worker to process messages for different chats, with the following requirements: Rate Limit: Each queue should have a rate limit of 1 job per 3 ...