goeventbus

EventBus for Golang

Description

This is a simple implementation of an event bus in golang. Actually support:

• publish/subscribe messaging.

Get Started

To start use eventbus in your project, you can run the following command.

go get github.com/stanipetrosyan/go-eventbus

And import

import (
	goeventbus "github.com/StaniPetrosyan/go-eventbus"
)

Publish/Subscribe

var eventbus = goeventbus.NewEventBus()

address := "topic"
options := goeventbus.NewMessageOptions().AddHeader("header", "value")
message := goeventbus.CreateMessage().SetBody("Hi Topic").SetOptions(options)

eventbus.Channel(address).Subscriber().Listen(func(dc goeventbus.Context) {
	fmt.Printf("Message %s\n", dc.Result().Data)
})

for {
	eventbus.Channel(address).Publisher().Publish(message)
	time.Sleep(time.Second)
}

Message

For publishing, you need to create a Message object using this method.

message := goeventbus.CreateMessage().SetBody("Hi Topic")

Each message can have some options:

options := goeventbus.NewMessageOptions().AddHeader("header", "value")
message := goeventbus.CreateMessage()

message.SetOptions(options)

eventBus.Channel("address").Publisher().Publish(message)

Processor

eventbus.Channel("topic1").Processor(func(message goeventbus.Message) bool {
	return logic
})