diff --git a/handler.go b/handler.go
index 9383673..249221f 100644
--- a/handler.go
+++ b/handler.go
@@ -48,6 +48,7 @@ func NewClient(addr, queueName string, opts ...Option) (*Client, error) {
 		logger:    log.New(os.Stdout, "", log.LstdFlags),
 		queueName: queueName,
 		done:      make(chan bool),
+		connected: make(chan struct{}),
 	}
 
 	o := options{