3 个仓库
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 是一个物联网设备通信框架和 Node.js 库,旨在管理嵌入式硬件与远程服务器或本地网络之间的双向数据交换。它作为一个 MQTT 硬件集成工具,将单板计算机连接到物联网云平台以进行远程管理和控制。 该项目提供了一个虚拟设备小部件管理器,用于将硬件状态与基于云的用户界面组件同步。该系统允许将远程 UI 标识符映射到内部软件逻辑,通过虚拟按钮和输入字段实现远程物联网控制。 该框架支持通过 MQTT 协议进行基于云的通信,以及通过共享无线连接进行直接的本地网络设备通信。它包括监听设备事件和管理双向数据流以触发硬件动作的能力。
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.