Hi everyone, I need to create a service which could receive messages from a FIFO data stream and send the messages in order to each client server. Let say the the data stream contains of A1, A2, A3, A4, B1,…
I am running RabbitMQ on a virtual machine of a local server (for development, testing, and staging environments). When there is an electrical power instability, the server ends up restarting, and RabbitMQ changes its internal IP address. Consequently, I have…
so far I am need to get Azure Queue messages and it releated to each others, for example: [{ id: 1, message: "this message should be executed first", timestamp: "2023-10-30" }, { id: 2, message: "this message should be executed…
I know it is possible to assign a priority to messages but this is not what I am looking for, I need to assign a priority to subscribers. For example, 2 services (A and B) are subscribed on the same…
Hi I have a publisher and consumer The registration for the publisher seems very simple services.AddMassTransit(x => { x.SetKebabCaseEndpointNameFormatter(); x.UsingAzureServiceBus((context, cfg) => { cfg.Host(configInstance.AzureServiceBusSettings.Connectionstring); cfg.AutoStart = true; } ); }); The registration for the consumer looks like this services.AddMassTransit(x =>…
According to Microsoft Docs: Auto-delete on idle enables you to specify an idle interval after which a queue or topic subscription is automatically deleted. The interval is reset when there is traffic on the entity. The minimum duration is 5…
I want to build a product the can perform some Internet scans (in Python) to collect various kinds of data. I want to design it with tasks that perform these collecting jobs. There can be multiple scans that run parallelly…
I am working on connecting my on premise app to Azure logic app. The problem here is that my network does not accept any inbound calls but is not limited in anyway to make outbound calls, so I have to…
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._bootstrap_external>", line 848, in exec_module File "<frozen…
I'm writing an HTTP API with expressjs in Node.js and here is what I'm trying to achieve: I have a regular task that I would like to run regularly, approx every minute. This task is implemented with an async function…