rabbitmq

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

type Registry struct {
}

type RegistryClient interface {
	Register(host string, port int, user string, password string) string
	DoPublish(amqpURI, exchange, exchangeType, routingKey, body string, reliable bool) error
	DoConsumer(amqpURI, exchange, exchangeType, routingKey, queue string) (*Consumer, error)
}