mdo fix

rabbitmq/connect.go

@@ -1,26 +0,0 @@
-package rabbitmq
-
-import (
-	"log"
-
-	"github.com/streadway/amqp"
-)
-
-func Open(url string) (*amqp.Connection, *amqp.Channel, error) {
-	conn, err := amqp.Dial(url)
-	if err != nil {
-		return nil, nil, err
-	}
-
-	ch, err := conn.Channel()
-	if err != nil {
-		log.Printf("Failed to open a channel: %v\n", err)
-		return nil, nil, err
-	}
-
-	return conn, ch, nil
-}
-
-func Close(conn *amqp.Connection) {
-	conn.Close()
-}