rabbitmq

type Connection interface {
	GetConn() *amqp.Connection
	GetChannel() *amqp.Channel
	SetReconnectHooks(...func())
}

type ConnectionOptions struct {
	URI string
}

type ExchangeOptions struct {
	Name          string
	Type          ExchangeType
	IsDurable     bool
	IsAutoDeleted bool
	IsInternal    bool
	NoWait        bool
	Args          map[string]interface{}
}

type ExchangeType uint8

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

type PublishOptions struct {
	Exchange    string
	RoutingKey  string
	IsMandatory bool
	IsImmediate bool
}

type Publisher interface {
	Publish(options *PublishOptions, message *Message) error
}

type PublisherOptions struct {
	URI string
}

type QueueOptions struct {
	Name          string
	Durable       bool
	AutoDelete    bool
	Exclusive     bool
	NoWait        bool
	MaxPriority   uint8
	RoutingKey    string
	QueueBindArgs map[string]interface{}
}

type Subscriber interface {
	Subscribe(handler func(message *Message))
}

type SubscriberOptions struct {
	URI             string
	QueueOptions    *QueueOptions
	ExchangeOptions *ExchangeOptions
	MaxPriority     uint8
	PrefetchCount   int
	Name            string
	AutoAck         bool
	NoWait          bool
	NoLocal         bool
	Exclusive       bool
	Args            map[string]interface{}
}