adapter

type Channel interface {
	DeclareQueue(name string) error
	DeclareExchange(name string) error
	BindQueue(queue, exchange string) error

	BufferCapacity(value uint16) error
	Consume(consumerID, queue string) (<-chan amqp.Delivery, error)
	Ack(deliveryTag uint64, multiple bool) error
	CancelConsumer(consumerID string) error

	Publish(exchange, key string, envelope amqp.Publishing) error
	Tx() error
	TxCommit() error
	TxRollback() error

	io.Closer
}

type Config struct {
	Username    string
	Password    string
	VirtualHost string
}

type Connection interface {
	Channel() (Channel, error)
	io.Closer
}

type Connector interface {
	Connect(ctx context.Context, socket net.Conn, config Config) (Connection, error)
}