messagebroker

type Consumer interface {
	Consume(queue string, onMessage func(body []byte)) error
}

type MessageBroker interface {
	Publisher
	Consumer
}

type PostgresqlConnectionConfig struct {
	Host     string // host (e.g. localhost) or path to unix domain socket directory (e.g. /private/tmp)
	Port     uint16 // default: 5432
	Database string
	User     string // default: OS user name
	Password string
}

type PostgresqlMessageBroker struct {
	// contains filtered or unexported fields
}

type Publisher interface {
	Publish(routing string, body []byte) error
}