testtest

def.go

@@ -29,7 +29,7 @@ type MQSession struct {
 	MQConnection *amqp.Connection
 	MQChannel    *amqp.Channel
 	MQQueue      *amqp.Queue
-	MQDelivery   <-chan *ampq.Delivery
+	MQDelivery   <-chan *amqp.Delivery
 	isConnected  bool
 }
 

mq.go

@@ -8,13 +8,13 @@ import (
 
 func (s MQSession) Open() error {
 	if s.isConnected {
-		return error.Error("Session is already connected.")
+		return errors.New("Session is already connected.")
 	}
 
 	if SLL == false {
 		s.MQConnection, err = amqp.Dial("amqp://" + Session.User + ":" + Session.Password + "@" + Session.Host + "/" + Session.Path)
 	} else {
-		return error.Error("SSL connection not implemented")
+		return errors.New("SSL connection not implemented")
 	}
 	logOnError(err, "Open : Failed to connect to RabbitMQ")
 	if err != nil {

workers.go

@@ -9,7 +9,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/streadway/amqp"
 	tb "gopkg.in/tucnak/telebot.v2"
 )