broker

type Controller interface {
	// SetLogger set a logger that will log operations on broker controller
	SetLogger(logger log.Interface)

	// Publish a message to the broker
	Publish(ctx context.Context, channel string, mw Message) error

	// Subscribe to messages from the broker
	Subscribe(ctx context.Context, channel string) (msgs chan Message, stop chan interface{}, err error)

	// SetQueueName sets the name of the queue that will be used by the broker
	SetQueueName(name string)
}

type Field string

type Message struct {
	CorrelationID *string
	Payload       []byte
}