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

mutex removed

Browse source
This commit is contained in:
nquidox 2026-04-03 10:27:01 +03:00
parent 5e8661cfcd
commit f23b388689
1 changed files with 0 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

8
service.go
View file

@ -8,10 +8,6 @@ import (
func (c *Client) handleReconnect(addr string) { func (c *Client) handleReconnect(addr string) {
for { for {
//c.mutex.Lock()
//c.isReady = false
//c.mutex.Unlock()
c.logger.Println("Connecting to server...") c.logger.Println("Connecting to server...")
conn, err := c.connect(addr) 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 { func (c *Client) handleReInit(conn *amqp.Connection) bool {
for { for {
//c.mutex.Lock()
//c.isReady = false
//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)