update imports and pub/sub configs - upgrade deps - use go 1.19

cmd/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"github.com/ThreeDotsLabs/event-driven-example/pkg"
 
 	"github.com/ThreeDotsLabs/watermill"
@@ -30,7 +31,7 @@ func main() {
 		panic(err)
 	}
 
-	err = router.Run()
+	err = router.Run(context.Background())
 	if err != nil {
 		panic(err)
 	}

docker-compose.yml

@@ -1,7 +1,7 @@
 version: '3'
 services:
   app:
-    image: golang:1.11
+    image: golang:1.19
     restart: on-failure
     ports:
       - 8080:8080

go.mod

@@ -1,10 +1,55 @@
 module github.com/ThreeDotsLabs/event-driven-example
 
+go 1.19
+
+require (
+	github.com/ThreeDotsLabs/watermill v1.1.1
+	github.com/ThreeDotsLabs/watermill-amqp v1.1.2
+	github.com/ThreeDotsLabs/watermill-http/v2 v2.0.1
+	github.com/ThreeDotsLabs/watermill-kafka/v2 v2.2.2
+)
+
 require (
-	github.com/DataDog/zstd v1.3.5 // indirect
-	github.com/Shopify/toxiproxy v2.1.4+incompatible // indirect
-	github.com/ThreeDotsLabs/watermill v0.3.0
-	github.com/go-chi/chi v4.0.1+incompatible // indirect
-	github.com/golang/snappy v0.0.1 // indirect
-	github.com/streadway/amqp v0.0.0-20190214183023-884228600bc9 // indirect
+	github.com/Shopify/sarama v1.32.0 // indirect
+	github.com/beorn7/perks v1.0.1 // indirect
+	github.com/cenkalti/backoff/v3 v3.2.2 // indirect
+	github.com/cespare/xxhash/v2 v2.1.1 // indirect
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/eapache/go-resiliency v1.2.0 // indirect
+	github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21 // indirect
+	github.com/eapache/queue v1.1.0 // indirect
+	github.com/go-chi/chi v4.0.2+incompatible // indirect
+	github.com/go-chi/render v1.0.1 // indirect
+	github.com/go-logr/logr v1.2.3 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/golang/snappy v0.0.4 // indirect
+	github.com/google/uuid v1.3.0 // indirect
+	github.com/hashicorp/errwrap v1.1.0 // indirect
+	github.com/hashicorp/go-multierror v1.1.1 // indirect
+	github.com/hashicorp/go-uuid v1.0.2 // indirect
+	github.com/jcmturner/aescts/v2 v2.0.0 // indirect
+	github.com/jcmturner/dnsutils/v2 v2.0.0 // indirect
+	github.com/jcmturner/gofork v1.0.0 // indirect
+	github.com/jcmturner/gokrb5/v8 v8.4.2 // indirect
+	github.com/jcmturner/rpc/v2 v2.0.3 // indirect
+	github.com/klauspost/compress v1.15.1 // indirect
+	github.com/lithammer/shortuuid/v3 v3.0.7 // indirect
+	github.com/matttproud/golang_protobuf_extensions v1.0.1 // indirect
+	github.com/oklog/ulid v1.3.1 // indirect
+	github.com/pierrec/lz4 v2.6.1+incompatible // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/prometheus/client_golang v1.11.0 // indirect
+	github.com/prometheus/client_model v0.2.0 // indirect
+	github.com/prometheus/common v0.26.0 // indirect
+	github.com/prometheus/procfs v0.6.0 // indirect
+	github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
+	github.com/streadway/amqp v0.0.0-20190404075320-75d898a42a94 // indirect
+	go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama v0.31.0 // indirect
+	go.opentelemetry.io/otel v1.6.1 // indirect
+	go.opentelemetry.io/otel/trace v1.6.1 // indirect
+	golang.org/x/crypto v0.0.0-20220321153916-2c7772ba3064 // indirect
+	golang.org/x/net v0.0.0-20220325170049-de3da57026de // indirect
+	golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e // indirect
+	google.golang.org/protobuf v1.26.0 // indirect
 )