broker

type Broker interface {
	Connect(brokerURL string) error
	GetTasks(queue string) <-chan *Message
	GetTaskResult(taskID string) <-chan *Message
	PublishTask(queueName string, taskID string, msg *Message, ignoreResults bool) error
	PublishTaskResult(taskID string, msg *Message) error
	PublishTaskEvent(taskID string, msg *Message) error
	Close() error
}

type Message struct {
	Timestamp   time.Time
	ContentType string
	Body        []byte
}