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)