mq

type Config struct {
	Addr          string
	Exchange      string
	ExchangeType  ExchangeKind // topic, direct, etc
	Queue         string
	RoutingKey    string
	ConsumerTag   string
	PrefetchCount int
	PrefetchSize  int
	ExchangeArgs  amqp.Table
	QueueArgs     amqp.Table
	QueueBindArgs amqp.Table
}

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

type ConsumerWorker interface {
	Consume(context.Context, []byte) error
}

type ExchangeKind string

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

type RabbitMqConsumer interface {
	Start()
	Stop()
}

type RabbitMqProducer interface {
	Destroy()
	Publish(interface{}) error
	PurgeQueue() error
}