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

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 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’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 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’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 using RabbitMQ with Spring AMQP and want to ensure reliable message delivery from the producer to the RabbitMQ broker. To achieve this, I've enabled Publisher Confirms and Publisher Returns. ...

I'm attempting to develop an understanding of the Saga and Outbox patterns, and am working on development now. I'm using RabbitMQ and NestJS. I've got three services, Orders, Inventory, and Shipping. ...

I'm implementing a job flow using BullMQ (latest version) with NestJS, and I've encountered an issue with error handling in flow jobs. The setup I have a parent flow job and multiple child jobs. The ...

I’m designing a multi-datacenter architecture using Apache Pulsar with geo-replication enabled. Architecture Overview: Apache Pulsar version: 4.0.2 Helm Chart version: pulsar-3.9.0 BookKeeper: 5 ...

We need to integrate two ERP systems which have to exchange many Entities (Items, Vendors, Prices ect.) and business Documents (Purchase orders, Sales orders, Warehouse transfer orders, ect.). The ...

I am testing my Pub/Sub setup with dead lettering enabled. Inside my subscriber application, I have not added any ack logic so all messages will not be acked by my subscriber. I set the maximum ...