An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: message-queue

rebus-org/Rebus

:bus: Simple and lean service bus implementation for .NET

Language: C# - Size: 450 MB - Last synced at: about 7 hours ago - Pushed at: 22 days ago - Stars: 2,574 - Forks: 370

excsn/rzmq

High Performance asynchronous, pure-Rust implementation of ZeroMQ messaging patterns, built upon the Tokio asynchronous runtime. Includes IO Uring and TCP Cork Support.

Language: Rust - Size: 1.91 MB - Last synced at: about 8 hours ago - Pushed at: about 10 hours ago - Stars: 14 - Forks: 4

rmqtt/rmqtt

MQTT Server/MQTT Broker - Scalable Distributed MQTT Message Broker for IoT in the 5G Era

Language: Rust - Size: 10.9 MB - Last synced at: about 9 hours ago - Pushed at: about 11 hours ago - Stars: 813 - Forks: 100

Chisanan232/abstract-backend-implementation-template

⛓️‍💥 A message queue component plugin implementation for abstract backend library

Language: Python - Size: 3.58 MB - Last synced at: about 20 hours ago - Pushed at: about 22 hours ago - Stars: 0 - Forks: 0

bravo1goingdark/blipmq

BlipMQ simplifies real-time communication between microservices and distributed systems with a lightweight, blazing-fast broker that just works — no complex setup, no compromises.

Language: Rust - Size: 5.65 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 19 - Forks: 1

rebus-org/Rebus.SqlServer

:bus: Microsoft SQL Server transport and persistence for Rebus

Language: C# - Size: 4.3 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 48 - Forks: 46

wx-chevalier/MessageQueue-Notes

深入浅出消息队列与消息中间件:Kafka、RabbitMQ、RocketMQ、Pulsar

Language: HTML - Size: 151 KB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 20 - Forks: 4

excsn/fibre

High-performance, memory-efficient, safe multimode sync <-> async channels built for real-time, low-overhead communication in concurrent Rust applications

Language: Rust - Size: 925 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 6 - Forks: 0

doocs/advanced-java

😮 Core Interview Questions & Answers For Experienced Java(Backend) Developers | 互联网 Java 工程师进阶知识完全扫盲:涵盖高并发、分布式、高可用、微服务、海量数据处理等领域知识

Language: Java - Size: 25.4 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 78,468 - Forks: 19,291

jgaskins/nats

NATS client in pure Crystal with JetStream support

Language: Crystal - Size: 1.27 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 26 - Forks: 3

cloudymoma/rustmq

Cloud-native distributed message queue with storage-compute separation architecture. Licensed under BDL 1.0 (academic use permitted, commercial use requires license).

Language: Rust - Size: 4.53 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 0

iamfarhad/LaravelRabbitMQ

RabbitMQ driver for Laravel Queue.

Language: PHP - Size: 295 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 29 - Forks: 2

jfish45/firestore-mqf

🔥 Streamline your data integration with Firestore using this simple and efficient message queue framework for seamless real-time processing.

Size: 1.29 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

cloudamqp/lavinmq

Ultra quick message queue and streaming server

Language: Crystal - Size: 8.26 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 808 - Forks: 43

emqx/emqx

The most scalable and reliable MQTT broker for AI, IoT, IIoT and connected vehicles

Language: Erlang - Size: 97.2 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 15,456 - Forks: 2,392

wolforest/clean-rocketmq

Clean-RocketMQ, help you understanding RocketMQ in 7 days. rewritten from scratch.

Language: Java - Size: 10 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 0

taoensso/carmine

Redis client + message queue for Clojure

Language: Clojure - Size: 2.61 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 1,178 - Forks: 134

pitabwire/frame

A simple bootstrap for quickly starting a server based on gocloud framework

Language: Go - Size: 2.17 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 5 - Forks: 2

RubassBaig/genstage_tutorial_2025

🚀 Explore job runner implementation in Elixir, improved from a decade ago. Ideal for both learners and seasoned developers looking for a practical case study.

Language: Elixir - Size: 1.38 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 0 - Forks: 0

ixian-platform/QuIXI

Quick integration toolkit for Ixian. Connects apps, IoT devices, AI Agents, and services to the Ixian Platform via REST APIs and message queues (MQTT/RabbitMQ). Provides developers with a simple bridge into secure Ixian communication and Client Discovery.

Language: C# - Size: 106 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 3 - Forks: 0

inngest/inngest-js

The developer platform for easily building reliable workflows with zero infrastructure for TypeScript & JavaScript

Language: TypeScript - Size: 11.7 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 761 - Forks: 85

lostclus/aiosafeconsumer

Safely consume and process data.

Language: Python - Size: 79.1 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 3 - Forks: 0

sarahosantos/kaf-s3

Kafka S3 Connector kaf-s3: A Python library that offloads Kafka messages to S3, with a producer and consumer using lightweight references and IAM-based access 🐙

Language: Python - Size: 27.3 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

AsmaaSoliman/C_Processes_Signals

C programs explore processes and signals for OS concepts. Learn process creation, synchronization, and signal handling with concise, practical exercises. 🐙

Language: C - Size: 11.7 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

redis/redis

For developers, who are building real-time data-driven applications, Redis is the preferred, fastest, and most feature-rich cache, data structure server, and document and vector query engine.

Language: C - Size: 195 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 71,563 - Forks: 24,303

DenisVazquez/erlang-ixm

🔧 Build and manage efficient data processing pipelines in Erlang with erlang-ixm, simplifying your workflow and enhancing performance.

Size: 1.29 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

sa6mwa/lockd

Distributed locking and messaging system for coordination and state management. Provides reliable locks, sequences, and queues on pluggable storage backends (disk, S3/MinIO). Designed for high availability, fencing, and AES-encrypted streaming I/O in Go.

Language: Go - Size: 721 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

bloomberg/blazingmq

A modern high-performance open source message queuing system

Language: C++ - Size: 105 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 3,035 - Forks: 155

celery/kombu

Messaging library for Python.

Language: Python - Size: 8.7 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 3,069 - Forks: 972

JustinTimperio/gpq

GPQ is a high performance embeddable double priority queue with complex priority ordering guarantees

Language: Go - Size: 697 KB - Last synced at: 5 days ago - Pushed at: 4 months ago - Stars: 57 - Forks: 5

Relton2031/firestore-mqf

🔥 Streamline your Firestore database with a message queue feature for efficient data processing and real-time updates.

Size: 1.29 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 0 - Forks: 0

lkpworkspace/myframe

C++ application framework(基于actor模型,微内核设计理念实现的C++组件化编程应用程序框架)

Language: C++ - Size: 1.16 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 38 - Forks: 6

weyoss/redis-smq

A simple high-performance Redis message queue for Node.js.

Language: TypeScript - Size: 10.9 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 645 - Forks: 63

noyzys/nautchkafe-rabbit-bridge

Lightweight, flexible, and functional message-passing pubsub system built with RabbitMQ

Language: Java - Size: 57.6 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 2 - Forks: 0

roger-castaldo/MQContract

A Messaging Contract based system

Language: C# - Size: 995 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 11 - Forks: 0

mizrael/OpenSleigh

OpenSleigh is a Saga management library for .NET Core.

Language: C# - Size: 2.61 MB - Last synced at: about 7 hours ago - Pushed at: 16 days ago - Stars: 328 - Forks: 39

Uzaird47/java_backend

🛒 Manage products and orders efficiently with this Java console application that allows registration, listing, searching, updating, and deletion of items.

Language: Java - Size: 1.3 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 0 - Forks: 1

pgmq/pgmq

A lightweight message queue. Like AWS SQS and RSMQ but on Postgres.

Language: PLpgSQL - Size: 1.67 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 3,965 - Forks: 114

redpanda-data/connect

Fancy stream processing made operationally mundane

Language: Go - Size: 35 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 8,491 - Forks: 899

nats-io/nats-server

High-Performance server for NATS.io, the cloud and edge native messaging system.

Language: Go - Size: 49.5 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 18,489 - Forks: 1,672

robustmq/robustmq

New generation of cloud-native and AI-native messaging infrastructure.

Language: Rust - Size: 52.2 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 1,374 - Forks: 195

GodcordOFFICIAL/KAFKA-RABBITMQ-REDIS-ELASTICHSEARCH-TURKCE-KAYNAK

🚀 Explore comprehensive Turkish documentation for Kafka, RabbitMQ, Redis, and Elasticsearch with practical examples and Docker support for easy setup.

Language: Shell - Size: 1.67 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 0 - Forks: 0

dymmond/asyncmq

Supercharge your async applications with tasks so fast, you’ll think you’re bending time itself.

Language: Python - Size: 771 KB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 72 - Forks: 4

vernemq/vernemq

A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases. The VerneMQ mission is active & the project maintained. Thank you for your support!

Language: Erlang - Size: 20.8 MB - Last synced at: 7 days ago - Pushed at: 10 days ago - Stars: 3,451 - Forks: 416

GauthamKrM/gomq-pool

A scalable and observable message queue system implemented in Go, featuring a concurrent consumer pool with retries, DLQ, and priority message handling. Built with RabbitMQ, Prometheus, Grafana, and Docker as part of learning Go concurrency and system design.

Language: Go - Size: 68.4 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 1 - Forks: 0

kubemq-io/kubemq-community

KubeMQ is a Kubernetes native message queue broker

Language: Go - Size: 3.96 MB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 668 - Forks: 47

shreyasganesh0/rabbitmq-game-pubsub Fork of bootdotdev/learn-pub-sub-starter

A real time text based multiplayer game based on Go and Rabbitmq for asynchronous message passing.

Language: Go - Size: 19.5 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 0 - Forks: 0

nikolaymatrosov/n8n-nodes-yc

n8n community nodes for Yandex Cloud services integration

Language: TypeScript - Size: 2.75 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 2 - Forks: 0

svix/svix-webhooks

The open source and enterprise-ready webhooks service 🦀

Language: Rust - Size: 12.2 MB - Last synced at: 7 days ago - Pushed at: 10 days ago - Stars: 2,970 - Forks: 217

falgun143/DJS

Distributed Job Scheduler with Fault Tolerance

Language: TypeScript - Size: 353 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 0 - Forks: 0

superstreamlabs/memphis

Memphis.dev is a highly scalable and effortless data streaming platform

Language: Go - Size: 468 MB - Last synced at: 9 days ago - Pushed at: over 1 year ago - Stars: 3,404 - Forks: 230

geofmureithi/apalis

Simple, extensible multithreaded background job and message processing library for Rust

Language: Rust - Size: 2.68 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 948 - Forks: 77

rednafi/hook-slinger

A generic service to send, retry, and manage webhooks

Language: Python - Size: 2.93 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 119 - Forks: 11

Chisanan232/abe-redis

🔗 A backend component as message queue component by Redis.

Language: Python - Size: 3.15 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 0 - Forks: 0

wesleywerikis/payment-gateway

💳 A hands-on project that simulates a real-world Payment Gateway architecture using Spring Boot, JMS (ActiveMQ), and REST APIs — featuring async payment processing, authorization rules, and webhook callbacks.

Language: Java - Size: 12.7 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 0 - Forks: 0

li-zheng-hao/LightMQ

基于数据库的消息队列/Database-based message queue

Language: C# - Size: 147 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 4 - Forks: 0

runreveal/kawa

A blazingly fast event stream processing library powering the reveald event processing daemon.

Language: Go - Size: 1 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 143 - Forks: 3

softwaremill/kmq

Kafka-based message queue

Language: Scala - Size: 456 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 337 - Forks: 44

whisperpine/rabbitmq-demo

RabbitMQ playground.

Language: Rust - Size: 45.9 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 0 - Forks: 0

jason810496/pgmq-sqlalchemy

More flexible PGMQ Postgres extension Python client that using SQLAlchemy ORM, supporting both async and sync engines, sessionmakers or built from dsn.

Language: Python - Size: 175 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 22 - Forks: 0

imqueue/core

Simple JSON-based messaging queue for inter service communication

Language: TypeScript - Size: 1.34 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 29 - Forks: 1

hailuand/corgimq

A lightweight Java message queue library built on your RDBMS.

Language: Java - Size: 848 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 3 - Forks: 1

giovanoh/aws-image-processor

Serverless image processor built with Go, AWS Lambda, S3, and SQS. Automatically creates thumbnails and medium-sized versions of uploaded images with optimized compression.

Language: Go - Size: 35.2 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 2 - Forks: 0

gamblevore/PicoMsg

Miniature Message Passing IPC System (Single Header C++ File)

Language: C++ - Size: 335 KB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 13 - Forks: 1

vgv/kolbasa

Small, efficient and capable Kotlin library to add Postgresql-based queues to your Java/Kotlin project

Language: Kotlin - Size: 2.18 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 19 - Forks: 2

imqueue/rpc

RPC-like client-service implementation over messaging queue

Language: TypeScript - Size: 1.01 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 27 - Forks: 1

lemunozm/message-io

Fast and easy-to-use event-driven network library.

Language: Rust - Size: 698 KB - Last synced at: 11 days ago - Pushed at: about 2 months ago - Stars: 1,184 - Forks: 82

visortelle/awesome-apache-pulsar

A curated list of resources about Apache Pulsar.

Size: 451 KB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 31 - Forks: 3

conorheffron/rabbitmq-tester

Tool for testing RabbitMQ instance.

Language: Java - Size: 70.3 KB - Last synced at: 13 days ago - Pushed at: 21 days ago - Stars: 3 - Forks: 0

turtacn/emqx-go

Golang implementation of EMQX, the most scalable and reliable MQTT broker for AI, IoT, IIoT and connected vehicles

Language: Go - Size: 38.9 MB - Last synced at: 6 days ago - Pushed at: 26 days ago - Stars: 21 - Forks: 13

mujibulhaquetanim/Backend-Functionalities

This is the playground of the Various Backend Tools (mostly implemented with Js runtimes)

Language: TypeScript - Size: 24.3 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 1 - Forks: 0

005-bot/tg-bot

Неофициальный Telegram-бот для уведомления жителей города Красноярска об аварийных и плановых отключениях коммунальных услуг.

Language: Python - Size: 326 KB - Last synced at: 16 days ago - Pushed at: 16 days ago - Stars: 0 - Forks: 0

rodrigo-speller/IntegrationFramework

Initiative to implement a modular framework of integration patterns, as proposed by Gregor Hohpe and Bobby Woolf in the "Enterprise Integration Patterns" book, in .Net Framewok's style 🚀.

Language: C# - Size: 85 KB - Last synced at: 3 days ago - Pushed at: about 6 years ago - Stars: 4 - Forks: 1

quangh33/Go-Kafka

A Kafka clone in Golang

Language: Go - Size: 626 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 65 - Forks: 6

nurmanhadi/microservices-product-service

Product Service is a microservice responsible for managing product and category data. It is designed using an Event-Driven Architecture and integrates with a Search Engine for efficient product discovery.

Language: Go - Size: 49.8 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 0 - Forks: 0

repejota/phpnats

A PHP client for the NATSio cloud messaging system.

Language: PHP - Size: 352 KB - Last synced at: 10 days ago - Pushed at: over 2 years ago - Stars: 238 - Forks: 98

sftpgo/sftpgo-plugin-pubsub

Publish/Subscribe systems integration for SFTPGo

Language: Go - Size: 348 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 9 - Forks: 4

jacobbailey8/oxmq

A simple and efficient distributed job queue for Go

Language: Go - Size: 48.8 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 1 - Forks: 0

joegasewicz/forestmq

Message queue 🌲

Language: C - Size: 1 MB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 9 - Forks: 0

lcarsde/lcarsde

lcarsde is the LCARS Desktop Environment, which consists of lcarswm and additional tool applications. This repository contains general information.

Language: Kotlin - Size: 370 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 108 - Forks: 5

rebus-org/Rebus.RabbitMq

:bus: RabbitMQ transport for Rebus

Language: C# - Size: 3.38 MB - Last synced at: 3 days ago - Pushed at: 19 days ago - Stars: 67 - Forks: 47

angelvargass/message-queue

Language: Go - Size: 14.6 KB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 0 - Forks: 0

rahad123/system-design-fundamentals

System Design Fundamentals

Size: 22.5 KB - Last synced at: 16 days ago - Pushed at: 20 days ago - Stars: 0 - Forks: 0

jaredwray/qified

Cloud Queues with Task and Messages and Multiple Providers

Language: TypeScript - Size: 888 KB - Last synced at: 16 days ago - Pushed at: 21 days ago - Stars: 6 - Forks: 2

moferry96/laravel-rabbitmq-communication

A package to work with RabbitMQ in an elegant way

Language: PHP - Size: 75.2 KB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 9 - Forks: 2

MichaelGehling/FeatureLoom

FeatureLoom is a C# development framework that focuses on a lean development and efficient code, speeds-up development by simplification while offering opt-in for a high level of control, promotes modular and extensible code by introducing means to easily decouple components with asynchronous communication, strives for high performance and a small memory footprint, equally supports synchronous and asynchronous programming to allow the right approach at the right time.

Language: C# - Size: 4.63 MB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 9 - Forks: 2

youngmonkeys/ezymq

Support to interact to Message Queue

Language: Java - Size: 671 KB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 0 - Forks: 4

GKunLi/redis-stream-queue

使用Redis Stream作为消息队列,消费者多实例可用且不需要改配置文件

Language: Java - Size: 11.7 KB - Last synced at: 22 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0

goldbergyoni/nodejs-testing-best-practices

Beyond the basics of Node.js testing. Including a super-comprehensive best practices list and an example app (April 2025)

Language: JavaScript - Size: 24.5 MB - Last synced at: 19 days ago - Pushed at: 7 months ago - Stars: 4,180 - Forks: 248

OptimalBits/bull

Premium Queue package for handling distributed jobs and messages in NodeJS.

Language: JavaScript - Size: 3.96 MB - Last synced at: 22 days ago - Pushed at: 11 months ago - Stars: 16,144 - Forks: 1,437

cevrimxe/RabbitMQ-Email-Service

RabbitMQ + Go + Docker: Publisher/Consumer pattern for scalable email delivery system with health checks and retry logic

Language: Go - Size: 7.81 KB - Last synced at: 22 days ago - Pushed at: 23 days ago - Stars: 0 - Forks: 0

smrchy/rsmq

Redis Simple Message Queue

Language: JavaScript - Size: 329 KB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 1,796 - Forks: 120

harshaweb/queue

A production-ready, high-performance message queueing system built on Redis Streams with Go

Language: Go - Size: 20.2 MB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 0 - Forks: 0

poundifdef/smoothmq

An improved drop-in replacement for SQS

Language: Go - Size: 4.95 MB - Last synced at: 23 days ago - Pushed at: 9 months ago - Stars: 2,253 - Forks: 50

CipherSecurityLab/CipherMQ

Unbreakable Security, Guaranteed and Exactly Once Delivery

Language: Rust - Size: 9.82 MB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 21 - Forks: 3

aman-1998/Point_To_Point_And_PubSub_Messaging

This repository focuses on point to point messaging and Publisher Subscriber messaging using Message Brokers. JMS 1 API and JMS 2 API both have been illustrated in detail using ActiveMQ Artemis. Also the cluster steup for multiple brokers is illustrated.

Language: Java - Size: 51.6 MB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 0 - Forks: 0

ella-to/bus

A Persistent and High-Performance Message Bus

Language: Go - Size: 304 KB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 1 - Forks: 0

indeedeng/iwf

iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes

Language: Go - Size: 12.5 MB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 614 - Forks: 57

libxengine/XEngine_MQService

c c++ message queue api service. c c++ 消息队列服务

Language: C++ - Size: 7.77 MB - Last synced at: 24 days ago - Pushed at: 25 days ago - Stars: 6 - Forks: 1

papra-hq/cadence-mq

Yet another job scheduling library for Node.js

Language: TypeScript - Size: 353 KB - Last synced at: 16 days ago - Pushed at: about 2 months ago - Stars: 5 - Forks: 0