I have a Spring Boot / Java application following Domain-Driven Design and Event-Driven Architecture. In my domain service, I create a ReservationCreatedEvent (a domain event) and publish it: ...

I'm working on an event-driven system using AWS SQS and facing a design decision when sending commands between services. The command triggers an operation in the receiving service, and that operation ...

This is my code : @retry(stop=stop_after_attempt(3), wait=wait_fixed(2)) def kafka_consumer(self): """Consume messages from Kafka with retry logic.""" ...

I'm working with Azure Event Grid to receive incoming events from an external publisher. When files are uploaded to a blob container named "snlf", I want my Service Bus trigger Function App ...

I'm building a piece of software responsible for processing different types of events from my system. This component is hosted as an Azure Function App, triggered by an Azure Storage Queue. The ...

I have subscribed to a Google pub/sub topic from my spring boot application with subscription.What happens if my service is down and There is some data which is pushed to pub/sub topic. Will i receive ...

I'm implementing a restaurant management micro-service using CQRS pattern. The read and write databases are separated and eventually become consistent by async events using an event bus. Now I want to ...

need help i am implementing CQRS using i would like to know which method i should choose when it comes to message delivery guarantees which one is suitable for CQRS if i choose at least one i will ...

In a microservice architecture, each service typically manages its own database and executes operations independently. However, when dealing with business processes that span multiple microservices, ...

Looking for an answer from a senior architect in Flutter who knows the in and out of the SDK and the platform. Objective is to get notified once a Stateful object comes to life or gets instantiated. ...

I have read a number of articles describing how websockets and pub sub architectures work at a high level. I get that with websockets a connection is persisted between a client and a server to send ...

Let's say we are building an application where the user has a dashboard populated with data from multiple services. For example: On the dashboard, Display pending notifications to be read, fed by ...

Consider there are 3 microservices - s1, s2 and s3. s1 sends message m1. s2 consumes message m1, applies some business logic and then sends message m2. The problem is that s3 receives message m2 ...

Lets imagine we have several bounded contexts and they are all decoupled using messaging services (queues, message buses). Some business process, lets say Order processing spans multiple bounded ...

In an event driven architecture using choreogeaphy model, how do we keep current, global state of the process? Lets say we have a process where many services p1,...,pn transition many states s1,...,...