messengers

type Message struct {
	Offset  int64  `json:"offset"`
	Message string `json:"message"`
	Subject string `json:"subject"`
}

type Messenger interface {
	// Check if the broker is reacheable.
	CanConnect() bool
	// Send sends a new message.
	Send(messageID, message string) error
	// Receive a new message from a specific subject.
	Receive(out chan<- Message)
}