From 5e8661cfcd9a30c8febece21a757649ab5f01209 Mon Sep 17 00:00:00 2001 From: nquidox Date: Thu, 2 Apr 2026 16:15:36 +0300 Subject: [PATCH] isReady disabled --- service.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/service.go b/service.go index c997307..cf6ccf1 100644 --- a/service.go +++ b/service.go @@ -8,9 +8,9 @@ import ( func (c *Client) handleReconnect(addr string) { for { - c.mutex.Lock() - c.isReady = false - c.mutex.Unlock() + //c.mutex.Lock() + //c.isReady = false + //c.mutex.Unlock() c.logger.Println("Connecting to server...") @@ -45,9 +45,9 @@ 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() + //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)