queue

type DeliveryMode uint8

type Options struct {
	URL             string
	ConnectAttempts int
	Exchange        struct {
		Name    string
		Type    string
		Durable bool
	}
}

type Publishing interface {
	GetBody() ([]byte, error)
	GetHeaders() amqp.Table
	SetHeaders(map[string]any)
	GetDeliveryMode() DeliveryMode
	GetRoutingKey() string
}

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