crystal-message-queue

Message Queue similar to NSQ
HEAD Latest release released
crystalmq/crystalmq
31 3 1
crystalmq

Archived shard

This shard has been archived . It is no longer maintained or has been discontinued for other reasons.

This repo seems to be no longer available at crystalmq/crystalmq.

Git synchronization failed . Last successful sync was .

Help find it again! … or have it archived.

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
crystal-message-queue:
  github: crystalmq/crystalmq
  
Crystal none

Dependencies 1

  • msgpack
    {'github' => 'benoist/msgpack-crystal'}

Development Dependencies 0

Dependents 0

Last synced .
search fire star recently