Skip to content

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

Notifications You must be signed in to change notification settings

Prashant-Surya/message-queue

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Instructions to Run

Start Server

$ ./setup
$ source venv/bin/activate
$ cd src/
$ python3 setup.py develop
$ cd ..
$ python3 start_server.py 9996

Run consumers

Open three different terminal windows and activate virtualenv using

$ source venv/bin/activate

This is important because the code is installed as a package in the virtualenv and imported wherever necessary. In each shell run:

$ python3 src/msgq/consumers/consumer_1.py
$ python3 src/msgq/consumers/consumer_2.py
$ python3 src/msgq/consumers/consumer_3.py

To produce messages:

We can run this as many times as we want as it generates random message everytime.

$ python3 src/msgq/producer/producer_1.py

About

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

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published