merch-tracker-v2/mt-rabbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

isReady disabled

Browse source
This commit is contained in:
nquidox 2026-04-02 16:15:36 +03:00
parent 8f967361e8
commit 5e8661cfcd
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
service.go
View file

@ -8,9 +8,9 @@ import (
func (c *Client) handleReconnect(addr string) { func (c *Client) handleReconnect(addr string) {
for { for {
c.mutex.Lock() //c.mutex.Lock()
c.isReady = false //c.isReady = false
c.mutex.Unlock() //c.mutex.Unlock()
c.logger.Println("Connecting to server...") 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 { func (c *Client) handleReInit(conn *amqp.Connection) bool {
for { for {
c.mutex.Lock() //c.mutex.Lock()
c.isReady = false //c.isReady = false
c.mutex.Unlock() //c.mutex.Unlock()
if err := c.init(conn); err != nil { if err := c.init(conn); err != nil {
c.logger.Printf("Failed to initialize connection: %s", err) c.logger.Printf("Failed to initialize connection: %s", err)