rabbitmq

type Exchange struct {
	ExchangeName string
	ExchangeType string
	Durable      bool
	AutoDelete   bool
	Internal     bool
	NoWait       bool
	Args         *amqp.Table
}

type IRabbitMQMessagingClient interface {
	PublishOnQueue(ctx context.Context, body []byte, exchange string) error
	SubscribeToQueue(consumerExchangeName string, handlerFunc func(amqp.Delivery) error) error
	Close()
}

type QueueDetails struct {
	QueueName    string
	ExchangeName string
	Durable      bool
	AutoDelete   bool
	Exclusive    bool
	NoWait       bool
	Args         *amqp.Table
}

type Queues struct {
	QueueDetails []QueueDetails
	Exchanges    []Exchange
}

type RabbitMQClient struct {
	Conn          *amqp.Connection
	Chann         *amqp.Channel
	Logger        *zap.Logger
	QueueBindings map[string]*amqp.Queue
}