meesage_broker

type Config interface {
	GetAmqpAddress() string
}

type Consumer interface {
	Consume(key string) (<-chan amqp.Delivery, error)
	QueueDeclare(key string) error
}

type Producer interface {
	Publish(key string, body []byte) error
	QueueDeclare(key string) error
}

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