1321 Open source projects that are alternatives of or similar to Qmq

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Fancy stream processing made operationally mundane

This is a Platform that collects all the data accuring in your Application and shows the data in real time by using Kibana or other tools.

OpenSleigh is a Saga management library for .NET Core.

Kafka library in Go

Simple Event Driven Microservices with Spring Cloud Stream

[READ-ONLY] Message queue bundle for Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, Async events, RPC over MQ and a lot more

The magic message bus

Telephone-ts: The "Event Emitter-less" TypeScript Event Architecture.

Building event-driven applications the easy way in Go.

信也科技MQ消息系统

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

a fast and simple distributed publish-subscribe messaging system (mq)

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message

Flume NG Canal source

450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Consul, Spark, Jenkins, Travis CI, Git, MySQL, Linux, DNS, Whois, SSL Certs, Yum Security Updates, Kubernetes, Cloudera etc...

基础框架

RabbitMQ Bundle for the Symfony2 web framework

A tiny wrapper over amqp exchanges and queues 🚌 ✨

A symfony bundle for swarrot integration

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Command Dispatcher, Processor, and Distributed Task Queue

A tiny wrapper around NSQ topic and channel 🚀

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

Spring Boot 2.x code examples

Best practice for hangfire samples

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

50+ DockerHub public images for Docker & Kubernetes - Hadoop, Kafka, ZooKeeper, HBase, Cassandra, Solr, SolrCloud, Presto, Apache Drill, Nifi, Spark, Consul, Riak, TeamCity and DevOps tools built on the major Linux distros: Alpine, CentOS, Debian, Fedora, Ubuntu

Another app which used to monitor the progress of Kafka Producer and Consumer

RabbitMQ-backed microservices supporting RPC, pubsub, automatic service discovery and scaling with no code changes.

RabbitMQ Extension for Yii2

乐檬框架之rabbitMQ的解耦实现方式（基于springboot框架），利用ConfirmCallback确保消息安全发送至broker服务器，使用Ack/Nack手动确认消息处理状态，保证broker消息被正确消费

🐂基于springcloud +dubbo构建的模拟秒杀项目，模块化设计，集成了分库分表、elasticsearch🔍、gateway、mybatis-plus、spring-session等常用开源组件

Microservice native message and event store for Postgres

DeFiBus=RPC+MQ，是基于开源消息中间件打造的安全可控的分布式金融级消息总线。

OpenMessaging Benchmark Framework

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.

Kombu is a messaging library for Python.

springboot和dubbo、netty的集成，redis mongodb的nosql模板， kafka rocketmq rabbit的MQ模板， solr solrcloud elasticsearch查询引擎

This repo contains a sample application based on a Garage Management System for Pitstop - a fictitious garage. The primary goal of this sample is to demonstrate several software-architecture concepts like: Microservices, CQRS, Event Sourcing, Domain Driven Design (DDD), Eventual Consistency.

Reliable messages resolve distributed transactions

This is the demo application that i created for my talk 'Microservice Architecture & Implementation with Asp.Net Core' at Dotnet İstanbul Meetup Group.

支持mysql、MongoDB数据变更订阅分发

A MessageBus (CommandBus, EventBus and QueryBus) implementation in PHP7

一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

MQ is a simple distributed in-memory message broker

NEventLite - An extensible lightweight library for .NET that manages the Aggregate lifecycle in an Event Sourced system. Supports Event and Snapshot storage providers like EventStore/Redis or SQL Server. Built with dependency injection in mind and seamlessly integrates with AspNetCore.

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

🚌 Simple and lean service bus implementation for .NET

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

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

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

python通用分布式函数调度框架 pip install function_scheduling_distributed_framework

🔀 FluentMediator is an unobtrusive library that allows developers to build custom pipelines for Commands, Queries and Events.

JavaScript pub/sub library based on RxJS

💨A well crafted go packages that help you build robust, reliable, maintainable microservices.