3 repositorios
Mechanisms for subscribing to event streams and mapping message payloads to internal application logic for asynchronous execution.
Distinct from Task-to-Response Mapping: None of the candidates cover the architectural pattern of consuming message broker events to trigger domain commands; they focus on API, hardware, or source mapping.
Explore 3 awesome GitHub repositories matching software engineering & architecture · Asynchronous Command Processing. Refine with filters or upvote what's useful.
This project is a reference implementation of Domain-Driven Design, Clean Architecture, and Command Query Responsibility Segregation (CQRS) patterns using the Go programming language. It serves as a sample application to demonstrate how to decouple core domain rules from infrastructure and delivery mechanisms. The system is built as a gRPC microservices architecture, utilizing type-safe communication and service contracts. It implements an event-driven architecture to manage eventual consistency and asynchronous processing, specifically employing the Outbox pattern to ensure reliable messagin
Subscribe to message topics and map payloads to application logic to execute tasks asynchronously.
blinker-js is an IoT device communication framework and Node.js library designed to manage bidirectional data exchange between embedded hardware and remote servers or local networks. It functions as an MQTT hardware integration tool that links single-board computers to IoT clouds for remote management and control. The project provides a virtual device widget manager to synchronize hardware state with cloud-based user interface components. This system allows for the mapping of remote UI identifiers to internal software logic, enabling remote IoT control through virtual buttons and input fields
Implements mechanisms for mapping incoming MQTT message payloads to internal hardware control logic asynchronously.
This project is a Java microservices reference implementation that demonstrates the application of structural design patterns for distributed systems. It consists of a suite of containerized services and infrastructure dependencies designed to showcase how to coordinate multiple independent services into a functional system. The implementation focuses on several advanced architectural patterns, including a centralized API gateway for routing and aggregating responses, Command Query Responsibility Segregation to separate read and write operations, and event sourcing to persist the state of bus
Processes domain commands asynchronously by subscribing to event streams and mapping payloads to business logic.