Repository navigation
messaging-queue
- Website
- Wikipedia
Memphis.dev is a highly scalable and effortless data streaming platform
Node.js client for Memphis. Memphis.dev is a highly scalable and effortless data streaming platform
Python client for Memphis. Memphis is an event processing platform
Nodejs project on microservices using RabbitMQ as messaging queue
Kafka producer and consumer example using spring boot
Rabbit MQ Demo
Automatic multi-tenancy for Node.js & typescript. We make it ASAP ( as simple as possible ).
Simple example showing how to send and receive messages with RabbitMQ using Go
Building a toy log ingestor to learn about queues, exchanges and routing keys.
Tracing library for microservices
This is a web back-end project in which three microservices are created. Uses Python Flask, SQLite3 Database and Redis for implementing Messaging Queue. The WorkerService is responsible for implementing a messaging queue when a user accesses the /postTweet endpoint. Along with that, it also includes a hashtag analysis method. When a user accesses the /trending endpoint, he/she will get the top trending hashtags. The User microservice includes creating user, authenticating user, add followers, remove followers. Timeline microservice posts a post on timeline, displays post of the user, displays post of all the follower’s user follows, Displays post of the all the users.
Pub-Sub HTTP based messaging queue
An Order Management System with Spring Boot example implementing Ports & Adapters / Hexagonal Architecture with Domain-Driven Design (DDD) principles.
me trying nsq because the name looks like a cool username
WonderQ a simple NodeJS messaging queue, with publisher and consumer
Aws sqs imple using spring boot
A simple Kafka-based coffee order system using Go. The producer sends coffee orders to Kafka, and the consumer processes and logs them.
practical demo of microservices communication using RabbitMQ and Spring Boot. Includes a producer and consumer service with real-world messaging patterns like direct exchange, routing keys, and queue bindings.