amqp

type Amqp interface {
	Init(opts ...Option)
	Options() Options
}

type Channel interface {
	Init(opts ...Option)
	Options() Options
	Publish(msg []byte)
	Consume(msg []byte)
}

type ChannelOptions struct {
	RabbitmqURL string
}

type Config struct {
}

type Connection interface {
	Init(opts ...Option)
	Options() Options
	Reconnect() error
}

type Consumer interface {
	Init(...ConsumerOption) error
	Options() ConsumerOptions
	Shutdown() error
}

type ConsumerHandle func(delivery Delivery, done chan error)

type ConsumerOption func(*ConsumerOptions)

type ConsumerOptions struct {
	Uri string

	Tag     string
	Key     string
	Handle  ConsumerHandle
	Conn    *amqp.Connection
	Channel *amqp.Channel
	// contains filtered or unexported fields
}

type Delivery = amqp.Delivery

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

type Option func(*Options)

type Options struct {
	Url  string
	Conn *amqp.Connection
}