Switch to the last Watermill version (#93)

[#61] Switch to the last Watermill version

Signed-off-by: Daniel Milchev fixed-term.daniel.milchev@bosch.io
Co-authored-by: Hristo Bozhilov <Hristo.Bozhilov@bosch.com>

NOTICE.md

@@ -46,17 +46,17 @@ Jeffail/gabs (2.6.0)
 * Project: https://github.com/Jeffail/gabs
 * Source:  https://github.com/Jeffail/gabs/releases/tag/v2.6.0
 
-ThreeDotsLabs/watermill (1.1.1)
+ThreeDotsLabs/watermill (1.3.2)
 
 * License: MIT License
 * Project: https://github.com/ThreeDotsLabs/watermill
-* Source:  https://github.com/ThreeDotsLabs/watermill/releases/tag/v1.1.1
+* Source:  https://github.com/ThreeDotsLabs/watermill/releases/tag/v1.3.2
 
-cenkalti/backoff (3.0.0)
+cenkalti/backoff (3.2.2)
 
 * License: MIT License
 * Project: https://github.com/cenkalti/backoff
-* Source:  https://github.com/cenkalti/backoff/releases/tag/v3.0.0
+* Source:  https://github.com/cenkalti/backoff/releases/tag/v3.2.2
 
 tidwall/sjson (v1.2.5)
 
@@ -112,23 +112,23 @@ gorilla/websocket (1.4.2)
 * Project: https://github.com/gorilla/websocket
 * Source:  https://github.com/gorilla/websocket/releases/tag/v1.4.2
 
-hashicorp/go-multierror (1.0.0)
+hashicorp/go-multierror (1.1.1)
 
 * License: Mozilla Public License 2.0
 * Project: https://github.com/hashicorp/go-multierror
-* Source:  https://github.com/hashicorp/go-multierror/releases/tag/v1.0.0
+* Source:  https://github.com/hashicorp/go-multierror/releases/tag/v1.1.1
 
-hashicorp/errwrap (1.0.0)
+hashicorp/errwrap (1.1.0)
 
 * License: Mozilla Public License 2.0
 * Project: https://github.com/hashicorp/errwrap
-* Source:  https://github.com/hashicorp/errwrap/releases/tag/v1.0.0
+* Source:  https://github.com/hashicorp/errwrap/releases/tag/v1.1.0
 
-lithammer/shortuuid (3.0.4)
+lithammer/shortuuid (3.0.7)
 
 * License: MIT License
 * Project: https://github.com/lithammer/shortuuid
-* Source:  https://github.com/lithammer/shortuuid/releases/tag/v3.0.4
+* Source:  https://github.com/lithammer/shortuuid/releases/tag/v3.0.7
 
 oklog/ulid (1.3.1)
 

cmd/connector/app/eventloop.go

@@ -126,7 +126,9 @@ func Run(
 	logger.Debugf("Provisioning file watcher created for %s", settings.Provisioning())
 
 	manager := conn.NewSubscriptionManager()
+
 	router := routing.CreateServiceRouter(localClient, manager, logger)
+	<-router.Running()
 	defer router.Close()
 
 	defer localClient.Disconnect()

go.mod

@@ -4,18 +4,18 @@ go 1.17
 
 require (
 	github.com/Jeffail/gabs/v2 v2.6.0
-	github.com/ThreeDotsLabs/watermill v1.1.1
+	github.com/ThreeDotsLabs/watermill v1.3.2
 	github.com/caarlos0/env/v6 v6.10.1
-	github.com/cenkalti/backoff/v3 v3.0.0
+	github.com/cenkalti/backoff/v3 v3.2.2
 	github.com/eclipse-kanto/kanto/integration/util v0.0.0-20221202082137-517d8d8a8766
 	github.com/eclipse/ditto-clients-golang v0.0.0-20220225085802-cf3b306280d3
 	github.com/eclipse/paho.mqtt.golang v1.4.1
 	github.com/fsnotify/fsnotify v1.5.1
 	github.com/google/go-tpm v0.3.2
-	github.com/hashicorp/go-multierror v1.0.0
+	github.com/hashicorp/go-multierror v1.1.1
 	github.com/imdario/mergo v0.3.12
 	github.com/pkg/errors v0.9.1
-	github.com/stretchr/testify v1.8.1
+	github.com/stretchr/testify v1.8.4
 	github.com/tevino/abool/v2 v2.0.1
 	github.com/tidwall/sjson v1.2.5
 	go.uber.org/goleak v1.1.10
@@ -27,10 +27,11 @@ require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/google/uuid v1.3.0 // indirect
 	github.com/gorilla/websocket v1.4.2 // indirect
-	github.com/hashicorp/errwrap v1.0.0 // indirect
-	github.com/lithammer/shortuuid/v3 v3.0.4 // indirect
+	github.com/hashicorp/errwrap v1.1.0 // indirect
+	github.com/lithammer/shortuuid/v3 v3.0.7 // indirect
 	github.com/oklog/ulid v1.3.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/rogpeppe/go-internal v1.11.0 // indirect
 	github.com/stretchr/objx v0.5.0 // indirect
 	github.com/tidwall/gjson v1.14.2 // indirect
 	github.com/tidwall/match v1.1.1 // indirect