messenger

type Consumer func(message Message)

type Handler[T any] func(handleable T) error

type Message struct {
	Id        string    `json:"id" bson:"_id"`
	Series    string    `json:"series" bson:"series"`
	Revision  int       `json:"revision" bson:"revision"`
	TimeStamp time.Time `json:"time_stamp" bson:"time_stamp"`
	Type      string    `json:"type" bson:"type"`
	Body      any       `json:"body" bson:"body"`
}

type Messenger interface {
	Receive(exchange string, name string) <-chan []byte
	Send(exchange string) chan<- []byte

	Errors() <-chan error
}