go-queue

Go queue provides a unified API across a variety of different queue backend like Redis, in-memory sync/async and RabbitMQ.

Features

RabbitMQ, in-memory sync/async backends.
Multiple message codecs (json, gob and msgpack) supported by go-encoding, you can also implement your own codecs.
Automatic message encoding and compression.
Support publishing raw messages for easy use with other languages.
Support for asynchronous task management and distribution.

go get -u github.com/ibllex/go-queue

For basic asynchronous message useage please see the example/raw

For asynchronous task useage please see the example/task

This library is under the BSD-2 license.

Name		Name	Last commit message	Last commit date
Latest commit History 43 Commits
.github/workflows		.github/workflows
example		example
internal		internal
memq		memq
rabbitmq		rabbitmq
.gitignore		.gitignore
LICENSE		LICENSE
README.md		README.md
bus.go		bus.go
consumer.go		consumer.go
consumer_test.go		consumer_test.go
go.mod		go.mod
go.sum		go.sum
message.go		message.go
queue.go		queue.go
task.go		task.go
task_test.go		task_test.go