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 एक IoT डिवाइस संचार फ्रेमवर्क और Node.js लाइब्रेरी है जिसे एम्बेडेड हार्डवेयर और रिमोट सर्वर या स्थानीय नेटवर्क के बीच द्विदिश डेटा विनिमय (bidirectional data exchange) को प्रबंधित करने के लिए डिज़ाइन किया गया है। यह एक MQTT हार्डवेयर एकीकरण टूल के रूप में कार्य करता है जो रिमोट प्रबंधन और नियंत्रण के लिए सिंगल-बोर्ड कंप्यूटर को IoT क्लाउड से जोड़ता है। यह प्रोजेक्ट हार्डवेयर स्थिति को क्लाउड-आधारित यूज़र इंटरफ़ेस घटकों के साथ सिंक्रनाइज़ करने के लिए एक वर्चुअल डिवाइस विजेट मैनेजर प्रदान करता है। यह सिस्टम रिमोट UI आइडेंटिफ़ायर को आंतरिक सॉफ़्टवेयर लॉजिक से मैप करने की अनुमति देता है, जिससे वर्चुअल बटन और इनपुट फ़ील्ड के माध्यम से रिमोट IoT नियंत्रण सक्षम होता है। यह फ्रेमवर्क 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.