message-busGo simple async message bus

package main

import (
    "fmt"
    "sync"

    messagebus "github.com/vardius/message-bus"
)

func main() {
    queueSize := 100
    bus := messagebus.New(queueSize)

    var wg sync.WaitGroup
    wg.Add(2)

    _ = bus.Subscribe("topic", func(v bool) {
        defer wg.Done()
        fmt.Println(v)
    })

    _ = bus.Subscribe("topic", func(v bool) {
        defer wg.Done()
        fmt.Println(v)
    })

    bus.Publish("topic", true)
    wg.Wait()
}
Documentation
Help
GitHub

Be production ready from day one

In modern cloud architecture, applications are decoupled into smaller, independent building blocks that are easier to develop, deploy and maintain. message-bus provide communication and coordination for these distributed applications.

message-bus can significantly simplify coding of decoupled applications, while improving performance, reliability and scalability.

Simplify development of event-driven microservices

Whether you’re just beginning your journey to event-driven asynchronous microservices or migrating an existing system, making your events accessible through messaging middleware is a critical early step.