GitHub topics: message-queue

Repositories

kbnim/elte-fi-opsys-assignment

Easter-themed assignment [Course: Operating Systems]

Language: C - Size: 38.1 KB - Last synced at: 25 days ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

KPravin/asset-management

Asset Management is a set of 3 microservices communicating with each other via a message broker.

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

mattbonnell/gq

gq is a lightweight scalable message queue backed by the most popular SQL DBs. Add message queue semantics to your application without integrating extra infrastructure.

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

absolute8511/nsq Fork of nsqio/nsq

A realtime distributed messaging platform.

Language: Go - Size: 29.4 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 113 - Forks: 12

andiserg/mqhandler

💬✅ Consumer of messages from Message Queue

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

mkrolczykk/IPC_message-queue

Inter-process communication (IPC) with use of linux message queues

Language: C - Size: 3.91 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

PickHD/LezPay

E-Wallet using golang.

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

khoakomlem/socketio-mq

A message broker using Socket.IO and Typescript

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

cminnoy/messaging

Multithreaded and coroutine messaging framework for C++14 and above.

Language: C++ - Size: 253 KB - Last synced at: 7 days ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

atayahmet/storage-based-queue 📦

Javascript queue library with persistent storage based queue mechanism for the browsers environments. Specially designed for offline.

Language: JavaScript - Size: 1.71 MB - Last synced at: 24 days ago - Pushed at: about 4 years ago - Stars: 43 - Forks: 5

anshyyy/Flight-Management-Backend-

A microservice backend for the flight bookings

Language: JavaScript - Size: 456 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

aashrafh/mars-OS Fork of mhomran/mars-OS

A simulation of an operating system that consists of two parts. The first part is a simulation for the CPU scheduler and the memory manager. The second part is the synchronizer which is a solution for the popular producer-consumer/shared buffer problem.

Language: C - Size: 1.06 MB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

hati-sh/hati

Hati is a key/value storage and message broker written in Go. TCP + JSON-RPC

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

rogerinn/hermes

Hermes is a modular framework for node.js to make gRPC APIs.

Language: TypeScript - Size: 312 KB - Last synced at: 2 days ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 1

paradoxical-io/cassieq

A distributed queue built off cassandra

Language: JavaScript - Size: 1.51 MB - Last synced at: about 1 year ago - Pushed at: almost 9 years ago - Stars: 51 - Forks: 2

kartik1998/redisq 📦

Redisq is an asynchronous task executor(worker) built for nodejs based on node-redis.

Language: JavaScript - Size: 1020 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 5 - Forks: 0

mscheruvathur/manifold

A complete backend APIs for centralized user authentication, using node Js, typescript and mongo dB -- [Micro Service] - still ongoing.

Language: TypeScript - Size: 65.4 KB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

xnnyygn/mqoo

my message queue prototype

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

kmlyteixeira/message-queue-dashboard

:dizzy: A study project using Next.JS to create a message board

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

prosenjitjoy/Go-with-NATS

Collection of example code used for learning NATS using Go.

Language: Go - Size: 19.5 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

kmlyteixeira/message-queue

:star2: A simple project to learn more about message queues

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

dictcp/docker-amqproxy

Language: Dockerfile - Size: 0 Bytes - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

Haalloobim/Tic-Tac-Toe_IPC-Implematation

A Tic Tac Toe Game with Shared Memory, Message Queue IPC Implementation in C langguage.

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

DigixGlobal/conduit_nsq

A NSQ adapter for conduit

Language: Elixir - Size: 65.4 KB - Last synced at: 20 days ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 0

N-Razzouk/dart_mq

DartMQ is a message-queue system that facilitates communication between different components in the application.

Language: Dart - Size: 381 KB - Last synced at: 10 months ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 2

vmware-archive/transport-go 📦

Transport is a full stack, simple, fast, expandable application event bus for your applications. It provides a standardized and simple API, implemented in multiple languages, to allow any individual component inside your applications to talk to one another. This is the Golang implementation of the Transport library.

Language: Go - Size: 922 KB - Last synced at: 7 months ago - Pushed at: about 2 years ago - Stars: 72 - Forks: 19

jason19970210/vehicleforensics

A simple project which performs the vehicle data logging for digital forensics usage as PoC

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

Klafyvel/PosixChannels.jl

PosixChannels provides an AbstractChannel-compatible channel using POSIX message queues.

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

mnindrazaka/hello-rabbitmq

Implementation of rabbitmq tutorial using Node.js

Language: JavaScript - Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

wh2per/IPC-and-MQTT-Protocol

Implement IPC and MQTT Protocol in Raspberry Pi 3

Language: Batchfile - Size: 175 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

muharik19/go-kafka

Learning Kafka and Connection Kafka To Golang Application

Language: Go - Size: 17.6 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

davesag/amqp-simple-pub-sub

A simple Pub Sub system that uses AMQP Messaging to exchange data between services

Language: JavaScript - Size: 3 MB - Last synced at: 15 days ago - Pushed at: 6 months ago - Stars: 20 - Forks: 4

Sreesanth46/rabbit-mq-example

RabbitMQ usage example for python

Language: Python - Size: 15.6 KB - Last synced at: 5 days ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

Israiloff/broker

JMS broker plugin

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

mig-elgt/broker

RabbitMQ Client to publish and subscribes queues using concurrency

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

NightFlightCaptain/sns

:ok_hand:仿照知乎做的问答web引用，使用springboot+mybatis+velocity开发，数据库使用mysql和redis，实现了消异步消息队列功能，配置solr实现全文搜索，包括敏感词过滤等其他功能

Language: CSS - Size: 1.68 MB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 1

siddhantshar24/Go-RabbitMQ

Go project implementation using RabbitMQ as messaging queue

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

jairov4/docker-activemq

Container for ActiveMQ

Language: Dockerfile - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

mattisonchao/raftsman 📦

toy

Language: Kotlin - Size: 84 KB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 1 - Forks: 0

AaronLiuIsCool/enterprise_integration_patterns_reading_notes

Enterprise Integration Patterns: Designing, Building, and Deploying Messaging Solutions READING notes in 2019

Size: 1.95 KB - Last synced at: about 1 year ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

yanyanran/yerMQ

An increasingly powerful message queue

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

aprilabank/mq-cli

mq - a little CLI tool to manage POSIX message queues

Language: Rust - Size: 11.7 KB - Last synced at: 9 days ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 1

miladr0/bull-mongo

Message Queue using Bull, Redis, and MongoDB in Nodejs

Language: JavaScript - Size: 46.9 KB - Last synced at: 3 months ago - Pushed at: over 4 years ago - Stars: 12 - Forks: 5

itlemon/rocketmq-5.0.0

RocketMQ源码之路

Language: Java - Size: 4.45 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

xljiadahao/Snippets

Java Code Snippets, learn, practice and reuse. There are topics about Message Queue, Dozer Mapper (deep clone), Java 8 Features, Concurrency with ThreadLocal and CountDownLatch, Hadoop, RxJava, Spring Statemachine.

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

maximthomas/openig-mb-example

Example OpenIG and message brokers integration

Size: 10.7 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

hossensyedriadh/spring-boot-kafka-demo

Basic demonstration of Apache Kafka message producer and consumer applications built with Java and Spring Boot

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

sontx/message-queue

A simple demo for windows/linux message queue

Language: C++ - Size: 24.4 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 3 - Forks: 1

omercelik-cs/inter-process-communication

Language: C - Size: 2.93 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 0 - Forks: 0

kodmq/kodmq

🧑‍💻 Message queue system for Node.js

Language: TypeScript - Size: 1.94 MB - Last synced at: 10 days ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

ywadi/crimsonq

One Message to Multi Consumer Queue with persistence and Queue Stages. Crimson Queue allows you to have multiple consumers listening on topics and receive a copy of a message that targets its topic providing multiple consumers for a queue message and complex message routing. Utilizes the same methodology as MQTT topic routing but with queue stages and persistence.,

Language: Go - Size: 153 MB - Last synced at: 7 months ago - Pushed at: over 3 years ago - Stars: 12 - Forks: 2

josethz00/postgres-mq

PostgresMQ is a project that implements a lightweight message-queue with PostgreSQL, using only native functions

Language: TypeScript - Size: 72.3 KB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 11 - Forks: 0

deepaksorthiya/spring-boot-jms-apache-artemis

Spring Boot JMS using Apache Artemis

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

getiot/mqtt-courses

MQTT 教程配套代码

Size: 0 Bytes - Last synced at: 4 months ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 0

getiot/zmq-courses

ZeroMQ 入门教程配套代码

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

pjcarly/drupal8-spectrum

Spectrum is a Drupal 8 framework.

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

node-xyz/xyz.rsmq.single.bootstrap

Redis Simple Message Queue bootstrap function for xyz

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

CyrilleStr/LinuxObjectIntercommunicationProject

Language: C - Size: 52.7 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

amirR01/Message-Queue

message queue and broker system similar to Kafka or RabbitMQ.

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

eao197/so-5-5

SObjectizer: it's all about in-process message dispatching!

Language: C++ - Size: 4.78 MB - Last synced at: 2 months ago - Pushed at: almost 5 years ago - Stars: 88 - Forks: 6

a-patel/LiteXMessageQueue

Abstract interface to implement any kind of message queue or service bus services (e.g. Azure ServiceBus, Azure Storage Queue, AmazonSQS, RabbitMQ, Google Cloud Queue, Redis Queue) for any type of application (ASP.NET Core, .Net Standard 2.x)

Size: 54.7 KB - Last synced at: 15 days ago - Pushed at: about 3 years ago - Stars: 3 - Forks: 0

adityashetty0302/rabbitmq-python-practice

Topic wise practice programs

Language: Python - Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

Cuis-Smalltalk/AMQP

AMQP client

Language: Smalltalk - Size: 34.2 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 0

marceloboeira/crowd

👥 [WIP] An experimental High Available Reverse Proxy for Massive Asynchronous Message Consumption

Language: Go - Size: 559 KB - Last synced at: 3 months ago - Pushed at: almost 6 years ago - Stars: 6 - Forks: 1

peterfraedrich/consulmq

Use k/v stores as message queues!

Language: Go - Size: 69.3 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 12 - Forks: 3

4paradigm/pafka Fork of apache/kafka

Pafka is originated from the OpenAIOS project to leverage an optimized tiered storage access strategy to improve overall performance for streaming/messaging system.

Language: Java - Size: 111 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 70 - Forks: 7

Prashant-Surya/message-queue

An implementation of the In-Memory message queue in python. With support for dependency handling.

Language: Python - Size: 8.79 KB - Last synced at: over 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 0

ducc/crdb-changefeed-publisher

Reads changefeeds from CockroachDB then sends them to a message queue!

Language: Rust - Size: 118 KB - Last synced at: 7 months ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 1

sahmad98/pyMessageBus

A python library for topic based messaging service.

Language: Python - Size: 20.5 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 1 - Forks: 0

yarenbenhur/ExchangeDemo

RabbitMQ message broker, .Net client library with samples.

Language: C# - Size: 38.1 KB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

yarenbenhur/ChatApp

Chat Application with RabbitMQ (ongoing process)

Language: CSS - Size: 4.67 MB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

g-leon/message-queue-service

Functional complete and local hermetic messaging queue with thread and process concurrency safety for Amazon SQS mocking

Language: Java - Size: 9.77 KB - Last synced at: over 1 year ago - Pushed at: over 8 years ago - Stars: 1 - Forks: 0

enowars/enowars3-service-deaddrop

A message queue written in Erlang for the ENOWARS 3 CTF

Language: Erlang - Size: 207 KB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

anthonydonx/sqs-example

SpringBoot with AWS Simple Message Queue tutorial

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

LTPRC/jigpipe

A demonstration of Baidu message queue Java-SDK which provides functions of publishing and subscribing in BIO and NIO modes.

Language: Java - Size: 2.59 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

islamghany/greenlight

Microservices application for movies.

Language: Go - Size: 8.69 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 7 - Forks: 2

rishabhpandey106/message_queue

How to set up BullMQ in NodeJs

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

masterghost2002/chat-nexus

In the dynamic landscape of real-time communication, the "ChatNexus" NPM module stands out as a robust solution designed to seamlessly integrate scalable chat functionality into Node.js servers. Engineered for efficiency and reliability, ChatScale harnesses the power of Redis and Socket.IO to create a high-performance environment for chat app

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

AyemunHossain/nodejs-rabbitmq-boilerplate

🚀 Jumpstart Your Node.js RabbitMQ with Our Boilerplate! Our Node.js Boilerplate provides a solid foundation for building modern and efficient applications. It includes essential tools, best practices, and a well-structured architecture, empowering you to focus on crafting outstanding features and functionalities. Let's build future ...

Language: JavaScript - Size: 17.6 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0