From 775aeecd74a68be52f08b422f0aa460e19162614 Mon Sep 17 00:00:00 2001
From: nquidox <nquidox@gmail.com>
Date: Mon, 4 May 2026 12:02:14 +0300
Subject: [PATCH] opts for new version of lib

---
 internal/tasks/handler.go | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/internal/tasks/handler.go b/internal/tasks/handler.go
index df04628..3cc1913 100644
--- a/internal/tasks/handler.go
+++ b/internal/tasks/handler.go
@@ -49,13 +49,22 @@ func New(deps Deps) TaskTransport {
 func (h *Handler) initConsumer(deps *Deps) error {
 	log.WithField("enabled", deps.LoggingEnabled).Debugf("%v rabbit mq logger", pkgLogHeader)
 
+	opts := rabbit.QueueOpts{
+		QueueName:  deps.TaskSourceQueue,
+		Durable:    true,
+		AutoDelete: false,
+		Exclusive:  false,
+		NoWait:     false,
+		Args:       nil,
+	}
+
 	client, err := rabbit.NewClient(rabbit.Address{
 		Username: deps.Username,
 		Password: deps.Password,
 		Host:     deps.Host,
 		Port:     deps.Port,
 		Vhost:    deps.Vhost,
-	}, deps.TaskSourceQueue, rabbit.WithLogging(deps.LoggingEnabled))
+	}, opts, rabbit.WithLogging(deps.LoggingEnabled))
 	if err != nil {
 		return err
 	}
@@ -65,13 +74,22 @@ func (h *Handler) initConsumer(deps *Deps) error {
 }
 
 func (h *Handler) initProducer(deps *Deps) error {
+	opts := rabbit.QueueOpts{
+		QueueName:  deps.TaskResultQueue,
+		Durable:    false,
+		AutoDelete: false,
+		Exclusive:  false,
+		NoWait:     false,
+		Args:       nil,
+	}
+
 	client, err := rabbit.NewClient(rabbit.Address{
 		Username: deps.Username,
 		Password: deps.Password,
 		Host:     deps.Host,
 		Port:     deps.Port,
 		Vhost:    deps.Vhost,
-	}, deps.TaskResultQueue, rabbit.WithLogging(deps.LoggingEnabled))
+	}, opts, rabbit.WithLogging(deps.LoggingEnabled))
 	if err != nil {
 		return err
 	}