Added error to return values in some functions

rabbitmq/connect.go

@@ -21,6 +21,6 @@ func Open(url string) (*amqp.Connection, *amqp.Channel, error) {
 	return conn, ch, nil
 }
 
-func Close(conn *amqp.Connection) {
-	conn.Close()
+func Close(conn *amqp.Connection) error {
+	return conn.Close()
 }