messagebroker

type Config struct {
	URL string
}

type Message struct {
	Payload []byte
}

type MessageBroker interface {
	// Publish publishes message to the topic
	Publish(topic string, message ...Message) error
	// Subscribe subscribes to a chanel mesagges of topic
	Subscribe(topic string) (chan Message, error)
	// Close end MessageBroker
	Close()
}