GitHub topics: message-queue

Repositories

LoadPulse/loadpulse-be

Language: Java - Size: 486 KB - Last synced at: about 2 months ago - Pushed at: 11 months ago - Stars: 2 - Forks: 0

dvdplm/rsmq-rust 📦

A Rust implementation of RSMQ

Language: Rust - Size: 29.3 KB - Last synced at: 3 days ago - Pushed at: about 5 years ago - Stars: 9 - Forks: 3

deepmancer/rabbitmq-rpc

RabbitMQ RPC is an async, ready-to-use Python framework for event-driven microservices.

Language: Python - Size: 62.5 KB - Last synced at: 8 months ago - Pushed at: 10 months ago - Stars: 5 - Forks: 0

bricevrs/go-rabbitmq-practice

A showcase of my skills in RabbitMQ using Go, featuring advanced messaging patterns, exchange handling, queue management, and optimized connection strategies.

Language: Go - Size: 8.79 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

Stream Tide is a distributed video streaming API for seamless video upload, management, and sharing, built with Node.js, TypeScript, PostgreSQL, Redis and FFmpeg for scalable and efficient content delivery.

Language: TypeScript - Size: 10.8 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

sh4run/message_queue

An inter-thread message queue implementation based on circular buffer and eventfd.

Language: C - Size: 12.7 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

Jobhdez/linear-social

a web service and interpreter for a very basic linear algebra language

Language: Python - Size: 363 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

xjtuwsn/cranemq

一个简单的Java消息队列，具有高效、可靠、分布式等特点 (A simple implemation of message queue in Java)

Language: Java - Size: 1.28 MB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 0

superstreamlabs/memphis.go

Go client for Memphis. Memphis is an event processing platform

Language: Go - Size: 521 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 40 - Forks: 17

kubemq-io/kubemq-Java 📦

Java client library for KubeMQ server

Language: Java - Size: 742 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 26 - Forks: 8

JMOrbegoso/OutboxInboxPatternSample

A sample of the transactional Outbox and Inbox patterns in C# and RabbitMQ.

Language: C# - Size: 87.9 KB - Last synced at: 3 months ago - Pushed at: almost 3 years ago - Stars: 1 - Forks: 0

VEuPathDB/lib-rabbit-job-queue

RabbitMQ based job queue library for client and server.

Language: Kotlin - Size: 440 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

GreedyKomodoDragon/Sybline

Sybline is a message broker aiming to simplify your backend while maintaining a highly avaliable in a secure manner

Language: Go - Size: 347 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

wesleysbmartins/go_rabbitmq_consumer

Esta aplicação é um exemplo de Consumer do RabbitMQ em Golang, nela utilizamos o pacote amqp, como um driver para integrar a aplicação ao message broker RabbitMQ.

Language: Go - Size: 58.6 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

obsidiandynamics/meteor

Real-time message streaming over a Hazelcast in-memory data grid

Language: Java - Size: 343 KB - Last synced at: 2 months ago - Pushed at: almost 3 years ago - Stars: 23 - Forks: 2

TravelXML/KAFKA-PYTHON-AWS-CRAWLER-AMAZON-ATHENA

A comprehensive tutorials / steps / scripts for setting up Apache Kafka on an Amazon EC2 instance, streaming logs to S3, and querying data with AWS Glue and Amazon Athena. Includes Zookeeper configuration, producer and consumer setup, and automated data catalog creation

Language: Jupyter Notebook - Size: 2.46 MB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

trandung2k1/learn-kafka

Language: JavaScript - Size: 6.84 KB - Last synced at: about 1 month ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

wesleysbmartins/go_rabbitmq_producer

Esta aplicação é um exemplo de Producer do RabbitMQ em Golang, nela utilizamos o pacote amqp, como um driver para integrar a aplicação ao message broker RabbitMQ.

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

lucasroc/servicebus-demo

Lab for demonstration of the Azure Service Bus messaging and features.

Language: C# - Size: 14.6 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

denosaurs/mess

🌀 A modern, broker-agnostic, distributed message queue for deno

Language: TypeScript - Size: 18.6 KB - Last synced at: 3 days ago - Pushed at: almost 2 years ago - Stars: 14 - Forks: 0

samiralavi/activecpp

Active Objects for Modern C++

Language: C++ - Size: 736 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 1 - Forks: 0

wesleysbmartins/rabbitmq

Estudos sobre RabbitMQ, que é um message broker altamente consolidado e utilizado por quem trabalha com comunicação entre sistemas.

Size: 12.7 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

benner-sistemas/messaging

A lightweight .NET standard messaging library for easily deal with any message broker, like RabbitMQ, ActiveMQ, AmazonSQS, AzureQueue, ...

Language: C# - Size: 375 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 4

socialpandas/sidekiq_monitor

Advanced monitoring for Sidekiq

Language: Ruby - Size: 911 KB - Last synced at: 22 days ago - Pushed at: about 10 years ago - Stars: 230 - Forks: 35

ryansmccoy/zmq-high-speed-subs

Example of High-Speed Subscriber Patterns in ZeroMQ

Language: Python - Size: 538 KB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 11 - Forks: 2

garvitgupta13/pizzeria

Tutorial to understand message queue system using python rq

Language: Python - Size: 6.84 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

arindas/laminarmq

A scalable, distributed message queue powered by a segmented, partitioned, replicated and immutable log.

Language: Rust - Size: 42.1 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 55 - Forks: 4

echlebek/lasr

In-process message queue

Language: Go - Size: 65.4 KB - Last synced at: 7 days ago - Pushed at: over 3 years ago - Stars: 5 - Forks: 2

muqiuhan/HanMQ

A simple message queue based on netty, complete routing distribution using basic topic mode

Language: Scala - Size: 477 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 3 - Forks: 1

konsumeio/konsume

:shipit: konsume seamlessly integrates message queues like RabbitMQ and Kafka with other services, automating data-driven actions.

Language: Go - Size: 488 KB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 5 - Forks: 2

RyanAquino/zadala

Zadala API is an ecommerce web API built with django rest framework.

Language: Python - Size: 333 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 4 - Forks: 0

crusty0gphr/config-loader-concept

Automated config loader with configuration how swapping services and NATs

Language: Go - Size: 6.18 MB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

skelmen/nestjs-azure-service-bus

Azure Service Bus module for Nest.js framework

Language: TypeScript - Size: 40 KB - Last synced at: 23 days ago - Pushed at: 11 months ago - Stars: 3 - Forks: 0

robaho/jnatsd

Java port of message broker service gnatsd from nats.io

Language: Java - Size: 95.7 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 1

semihbkgr/go-rsmq

A lightweight message queue for Go that requires no dedicated queue server.

Language: Go - Size: 150 KB - Last synced at: 3 months ago - Pushed at: 7 months ago - Stars: 5 - Forks: 1

Abdullah-dev0/redis-example-message-queue

Redis Messaging Queue Example

Language: TypeScript - Size: 19.5 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

lecardozo/rworker

Celery worker for R tasks! Celery :left_right_arrow: R

Language: R - Size: 176 KB - Last synced at: 7 months ago - Pushed at: about 4 years ago - Stars: 27 - Forks: 9

InfeCtlll3/pythonmq

Native sqlite3 messagequeue system written in python 3

Language: Python - Size: 23.4 KB - Last synced at: 11 months ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

kortirso/ex_worker

Message processing with elixir

Language: Elixir - Size: 33.2 KB - Last synced at: 5 days ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0

Lazzaretti/vscode-message-queue-explorer

Tool to view and interact with message queues for Visual Studio Code

Language: TypeScript - Size: 144 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

farawayCC/lowmq

Simple to use Message Broker implemented as REST API

Language: JavaScript - Size: 256 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 7 - Forks: 1

bruce-mig/fraud-detection

fraud detection distributed system

Language: Java - Size: 516 KB - Last synced at: 3 months ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0

mohammad-safari/serverless-authentication

microservice serverless exercise of cloud computing course - aut 1402-1403 fall

Language: Java - Size: 120 KB - Last synced at: 7 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

SajjadAli54/reactjs

Enterprise Application Development Course Material

Language: JavaScript - Size: 4.84 MB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 1 - Forks: 0

marcobarcelos/node-msmq

A MSMQ implementation for node.js

Language: C# - Size: 6.84 KB - Last synced at: 12 days ago - Pushed at: almost 7 years ago - Stars: 8 - Forks: 10

icsharp/Hangfire.Topshelf

Best practice for hangfire samples

Language: C# - Size: 887 KB - Last synced at: about 2 months ago - Pushed at: over 8 years ago - Stars: 207 - Forks: 62

violetpay-org/queue-manager

Queue manager designed to manage multiple streamable queues with one cue.

Language: Go - Size: 52.7 KB - Last synced at: about 2 months ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0

mehmetgoren/smcp

Feniks iNVR Smart Cloud Provider Service

Language: Go - Size: 7.7 MB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 4

mori-b/aioconnectors

Simple secure asynchronous message queue

Language: Python - Size: 729 KB - Last synced at: 11 months ago - Pushed at: 12 months ago - Stars: 19 - Forks: 3

sskender/advanced-operating-systems

Advanced Operating Systems FER labs

Language: C - Size: 77.1 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

MengRao/PubSubQueue

An efficient single publisher multiple subscriber message queue for Linux IPC

Language: C++ - Size: 26.4 KB - Last synced at: 11 months ago - Pushed at: almost 5 years ago - Stars: 53 - Forks: 20

tradologics/queuet

QueueT - Dead simple, Redis-based, message broker for Node.js

Language: JavaScript - Size: 103 KB - Last synced at: 20 days ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 1

xiaozhiliaoo/mq-practice

Research on message queue: activemq,rabbitmq,rocketmq,kafka,pulsar

Language: Java - Size: 152 MB - Last synced at: 3 months ago - Pushed at: 12 months ago - Stars: 4 - Forks: 1

Lisprez/srq

It is a Simple and Stupid Message Queue based on Redis

Language: Go - Size: 5.86 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 0

kianian9/Masih

Automated Message Queue Orchestrator For Parallelized Benchmaking.

Language: Go - Size: 77.1 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 0

langgo/msmq

msmq is a message queue base on mysql

Language: Go - Size: 30.3 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 0

jakoblorz/brokerutil

brokerutil provides a common interface to message-brokers for pub-sub applications

Language: Go - Size: 357 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 0 - Forks: 0

vtsykun/cron-bundle

:clock3: Docker friendly Symfony Cron Bundle for handling scheduled tasks consistently, parallel or via message queue

Language: PHP - Size: 227 KB - Last synced at: 22 days ago - Pushed at: about 1 year ago - Stars: 18 - Forks: 5

takashabe/go-pubsub

It is a pubsub server that can be operated with the REST API.

Language: Go - Size: 268 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 4 - Forks: 4

eko234/sique

A rather simple inmemory message queue for golang

Language: Go - Size: 2.93 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

gokultp/hashqd

a distributed hashed message broker

Language: Go - Size: 1.47 MB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0

mrkagelui/alfred

Reliable, Efficient and Idempotent Distribution of Laborious, Runtime-Error-Ridden Jobs

Language: Go - Size: 1.21 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

wins1908/redis-queue

Redis queue wrapper based on https://github.com/adjust/rmq

Language: Go - Size: 8.79 KB - Last synced at: over 2 years ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

dimpu47/distributedElections

Building a Distributed System with Flexible Data while Exposing data & functionality through RESTful Web Service API

Language: Go - Size: 6.91 MB - Last synced at: over 2 years ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

ColinSullivan1/nats-client-sim

A NATS Client Simulator

Language: Go - Size: 1.4 MB - Last synced at: about 2 years ago - Pushed at: almost 6 years ago - Stars: 1 - Forks: 1

official-stallion/stallion

Fast message broker implemented with Golang.

Language: Go - Size: 128 KB - Last synced at: about 5 hours ago - Pushed at: almost 2 years ago - Stars: 42 - Forks: 0

George-Novikov/Letterwind-Example

This is an example project for the Letterwind library.

Language: Java - Size: 700 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

George-Novikov/Letterwind

An embedded message broker in the form of a Java library. Performs multi-threaded tasks both locally and remotely without additional applications.

Language: Java - Size: 361 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

JHLeeeMe/IPCplusplus

System V IPC c++ wrapper

Language: C++ - Size: 40 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

inaciogu/go-sqs

Easy-to-use Golang package for consuming messages from AWS SQS

Language: Go - Size: 98.6 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 9 - Forks: 1

amburi/rabbitmq-with-docker

This tutorial demonstrates a simple publisher-consumer pattern using RabbitMQ as a message broker. We'll use Node.js and Docker Compose to set up the project easily and manage dependencies.

Language: JavaScript - Size: 9.77 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

TKPM-2023/helmet-shop

Helmet Shop Backend Project With Golang, Gorm, MySQL, Docker

Language: Go - Size: 21.8 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 1

sovisrushain/recharge-system

Messaging between java microservices using Kafka

Language: Java - Size: 101 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

pilotpirxie/message-queue-dashboard

⏩ GUI Dashboard for SQS and ElasticMQ with CI/CD consumer.

Language: JavaScript - Size: 210 KB - Last synced at: 4 months ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0

HossamGeek/nats-event-service

The NatsService is a comprehensive service layer designed to facilitate interaction with the NATS messaging system, offering a robust set of functionalities tailored for efficient and flexible message handling across distributed systems.

Language: TypeScript - Size: 85.9 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

pinopino/LightMessager

rabbitmq的简易封装，支持常见使用场景

Language: C# - Size: 186 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 2

shiblon/entroq

Competing-consumer fault-tolerant task queues. Written in Go.

Language: Go - Size: 9.24 MB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 22 - Forks: 4

akarshippili/networking

Examples of computer networks concepts

Language: Go - Size: 110 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

coin8086/cloudworker

A queue-based system on cloud for high-throughput and parallel workload

Language: C# - Size: 373 KB - Last synced at: 8 months ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

fishtrip/watchman

A simple message queue callback center

Language: Go - Size: 11.7 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 289 - Forks: 69

mrusamamuzaffar/static_chat_screen

This is demo chat screen. You can add message to the sender side by simply pressing the send button and to add message to the receiver side, you have to long press the same send button.

Language: Dart - Size: 62.5 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1

DotNetBackendTraining/server-monitoring-system

A Server Monitoring and Notification System.

Language: C# - Size: 54.7 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

n25a/eavesdropper

Eavesdropper is project that used for consuming in message queue and storing in database.

Language: Go - Size: 63.5 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 7 - Forks: 0

meltaxa/slackmq

A Slack Message Queue system. For a minimalist architecture, leverage the power of SlackMQ to design a Slack bot that is highly available out of the box.

Language: Python - Size: 36.1 KB - Last synced at: 27 days ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 1

Monica-Gullapalli/PortfolioPulse-Django-WebApp

A Financial Portfolio App in Django

Language: Python - Size: 61.6 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

octu0/nats-relay

Relay(replicate) one or any Topics in NATS server to another NATS server.

Language: Go - Size: 104 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 6 - Forks: 3

restuwahyu13/csv-streaming

Example implementation CSV streaming data as worker service

Language: Go - Size: 36.1 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 1

nilorg/eventbus

Go EventBus 事件总线

Language: Go - Size: 104 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 1

gabrielddantas/Alura-Microservice-ASync-Communication

This application is a study on microservices, where microservices were created for orders and payments. In this application, the concept of asynchronous communication was applied.

Language: Java - Size: 128 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0