3 repository-uri
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 este un framework de comunicare IoT și o bibliotecă Node.js concepută pentru a gestiona schimbul bidirecțional de date între hardware-ul embedded și serverele la distanță sau rețelele locale. Funcționează ca un instrument de integrare hardware MQTT care leagă computerele single-board de cloud-urile IoT pentru gestionare și control de la distanță. Proiectul oferă un manager de widget-uri pentru dispozitive virtuale, pentru a sincroniza starea hardware-ului cu componentele interfeței utilizator bazate pe cloud. Acest sistem permite maparea identificatorilor UI de la distanță către logica software internă, permițând controlul IoT de la distanță prin butoane virtuale și câmpuri de introducere a datelor. Framework-ul suportă atât comunicarea bazată pe cloud prin protocolul MQTT, cât și comunicarea directă între dispozitive în rețeaua locală prin conexiuni wireless partajate. Include capabilități pentru ascultarea evenimentelor dispozitivului și gestionarea fluxurilor de date bidirecționale pentru a declanșa acțiuni hardware.
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.