Forcing multiple unsubscribes before new subscribe

topfreegames · Jul 28, 2017 · 66b5ad9 · 66b5ad9
1 parent 2da35e1
commit 66b5ad9
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/bot/mqtt_bot.go b/bot/mqtt_bot.go
@@ -102,7 +102,13 @@ func (b *MQTTBot) StartBot() {
 				MessagePattern: pMap[string("messagePattern")].(string),
 			})
 		}
-		client.Unsubscribe(topic)
+
+		for i := 0; i < 10; i++ {
+			if tokenUnsubscribe := client.Unsubscribe(topic); tokenUnsubscribe.Wait() && tokenUnsubscribe.Error() != nil {
+				logger.Logger.Info(tokenUnsubscribe.Error())
+			}
+		}
+
 		if token := client.Subscribe(topic, uint8(qos), h); token.Wait() && token.Error() != nil {
 			logger.Logger.Fatal(token.Error())
 		}

diff --git a/test_containers/docker-compose.yml b/test_containers/docker-compose.yml
@@ -8,12 +8,13 @@ services:
     networks:
       - mosqnet
   mosquitto:
-    image: jllopis/mosquitto:v1.4.9
+    image: erlio/docker-vernemq
     ports:
       - "1883:1883"
     environment:
       - DOMAIN=example.local
       - PORT=8080
+      - DOCKER_VERNEMQ_ALLOW_ANONYMOUS=on
     networks:
       - mosqnet
     depends_on: