crystal-message-queue
About this project
This project is a Message Queue written in Crystal, very similar to NSQ.
Usage
To run this project you will need three components.
-
A Message Router, running with either debug set to true or false
crystal router.cr false
-
A Message Consumer, with a topic and channel set
crystal tools/consumer.cr my_topic my_channel
-
A Message Producer, with a topic and message
crystal tools/producer.cr my_topic "Hello World"
-
If you would like to run the benchmarks, feel free to use tools/meth
./meth --consumer # Will benchmark received messags (used in conjuction with producer)
./meth --producer # Will benchmark sent messages (used in conjunction with consumer)
./meth --latency # Will benchmark request latency