diff --git a/mq.go b/mq.go
index e7b9ff7..c331444 100644
--- a/mq.go
+++ b/mq.go
@@ -7,5 +7,5 @@ import (
 func (c *MQClient) Open() error {
 	conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
 	c.Connection = conn
-	return null
+	return err
 }