From f23b3886890d8c38bf446ac377660176ca41e7df Mon Sep 17 00:00:00 2001
From: nquidox <nquidox@gmail.com>
Date: Fri, 3 Apr 2026 10:27:01 +0300
Subject: [PATCH] mutex removed

---
 service.go | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/service.go b/service.go
index cf6ccf1..6e3355d 100644
--- a/service.go
+++ b/service.go
@@ -8,10 +8,6 @@ import (
 
 func (c *Client) handleReconnect(addr string) {
 	for {
-		//c.mutex.Lock()
-		//c.isReady = false
-		//c.mutex.Unlock()
-
 		c.logger.Println("Connecting to server...")
 
 		conn, err := c.connect(addr)
@@ -45,10 +41,6 @@ func (c *Client) connect(addr string) (*amqp.Connection, error) {
 
 func (c *Client) handleReInit(conn *amqp.Connection) bool {
 	for {
-		//c.mutex.Lock()
-		//c.isReady = false
-		//c.mutex.Unlock()
-
 		if err := c.init(conn); err != nil {
 			c.logger.Printf("Failed to initialize connection: %s", err)