Updated deps after several years :) (#50)

* Updated deps after several years :)

* Migrated to official rabbit driver

* Updated go version to 1.16

.github/workflows/go.yml

@@ -5,7 +5,7 @@ jobs:
   test:
     strategy:
       matrix:
-        go-version: [1.14.x, 1.15.x, 1.16.x, 1.17.x, 1.18.x, 1.19.x]
+        go-version: [1.16.x, 1.17.x, 1.18.x, 1.19.x]
     runs-on: ubuntu-latest
     services:
       rabbitmq:

README.md

@@ -19,6 +19,10 @@ go-mq supports both sync and async producers.
 go-mq has auto reconnects on closed connection or network error.
 You can configure delay between each connect try using `reconnect_delay` option.
 
+### Minimal go version
+
+1.16
+
 ## Install
 
 `go get -u github.com/cheshir/go-mq`

config.go

@@ -4,7 +4,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/streadway/amqp"
+	amqp "github.com/rabbitmq/amqp091-go"
 )
 
 // DeliveryMode describes an AMQP message delivery mode.
@@ -82,6 +82,7 @@ type QueueConfig struct {
 
 func (config QueueConfig) normalize() {
 	config.BindingOptions.normalizeKeys()
+	//config.BindingOptions.buildArgs()
 	config.Options.normalizeKeys()
 	config.Options.buildArgs()
 }
@@ -183,7 +184,7 @@ func (options Options) convertArgsToAMQPTable(args interface{}) amqp.Table {
 
 	switch arguments := args.(type) {
 	case map[string]interface{}:
-		table = amqp.Table(arguments)
+		table = arguments
 	case map[interface{}]interface{}:
 		table = make(amqp.Table, len(arguments))
 

go.mod

@@ -1,11 +1,11 @@
 module github.com/cheshir/go-mq
 
-go 1.14
+go 1.16
 
 require (
-	github.com/NeowayLabs/wabbit v0.0.0-20200409220312-12e68ab5b0c6
-	github.com/google/uuid v1.1.1 // indirect
-	github.com/pborman/uuid v1.2.0 // indirect
-	github.com/streadway/amqp v0.0.0-20200108173154-1c71cc93ed71
+	github.com/NeowayLabs/wabbit v0.0.0-20210927194032-73ad61d1620e
+	github.com/google/uuid v1.3.0 // indirect
+	github.com/pborman/uuid v1.2.1 // indirect
+	github.com/rabbitmq/amqp091-go v1.5.0
 	gopkg.in/yaml.v1 v1.0.0-20140924161607-9f9df34309c0
 )

mq.go

@@ -12,7 +12,7 @@ import (
 	"github.com/NeowayLabs/wabbit/amqp"
 	"github.com/NeowayLabs/wabbit/amqptest"
 	"github.com/NeowayLabs/wabbit/utils"
-	amqpDriver "github.com/streadway/amqp"
+	amqpDriver "github.com/rabbitmq/amqp091-go"
 )
 
 const (