README
¶
messenger
📬 A minimalistic library for abstracting asynchronus messaging (inspired by Vice)
Installation
Adding messenger to your Go module is as easy as calling this command in your project
go get github.com/coze-cloud/messenger
Usage
Being a minimalistic library, messenger only provides the basics. In essence the basics are transport layer abstractions and a simple (but opinonated) message implementation. The later however is completly independend from the transport layer. Thus you can easily build your own way of handling messages!
Currently supported transports are:
- In-Memory / Local
- RabitMQ / AMQP
- Redis Streams
Setting up a messenger
ctx, cancel := context.WithCancel(context.Background)
defer cancel()
msgr := local.NewLocalMessenger(ctx)
Receiving data
Receiving and sending data utilizes Go channels, which work just as you expect them to!
The abstraction and thus the use of exchange and consumer in messenger is heavily inspired by the way messages are processed by RabbitMQ using the Publish/Subscribe transport.
data, ok := <- msgr.Receive("exchange", "consumer")
if !ok {
// Channel is closed, so no further data will arrive
return
}
fmt.Println(string(data))
Sending data
msgr.Send("exchange") <- []byte("Hello world!")
IMPORTANT: Do not close send channels after no furhter transmission will take place, as they are shared instances acros the life of your program.
Copyright © 2022 - The cozy team & contributors
Directories