rabbitmq

type Client interface {
	ChannelOpen(name string) error
	ExchangeDeclare(name string, typeStr string) error
	QueueDeclare(name string) (amqp.Queue, error)
	QueueBind(queueName string, bindingKey string, exchangeName string) error
}

type Consumer interface {
	OpenChannel() error
	Subscribe() (<-chan amqp.Delivery, error)
	CleanUp() error
}

type ConsumerConfig struct {
	AmqpURI        string
	ConnectionName string
	QueueName      string
	Ctag           string
}

type Producer interface {
	OpenChannel() error
	Publish([]byte, context.Context) error
	CleanUp() error
}

type ProducerConfig struct {
	AmqpURI        string
	ConnectionName string
	ExchangeName   string
	RoutingKey     string
}