Receive an unlimited amount of events

* Removes the original cap of 1000 messages.

Signed-off-by: Alex Ellis (OpenFaaS Ltd) <[email protected]>

README.md

@@ -20,6 +20,10 @@ Component parts:
 
 See [helm chart](chart/mqtt-connector) for deployment instructions. Then continue at "Test the connector".
 
+```sh
+TAG=0.2.0 make build push
+```
+
 ## Deploy out of cluster
 
 ```sh

chart/mqtt-connector/Chart.yaml

@@ -1,7 +1,7 @@
 apiVersion: v1
 description: Connect OpenFaaS functions to MQTT
 name: mqtt-connector
-version: 0.1.1
+version: 0.2.0
 sources:
 - https://github.com/openfaas-incubator/mqtt-connector
 home: https://www.openfaas.com

chart/mqtt-connector/values.yaml

@@ -1,4 +1,4 @@
-image: alexellis2/mqtt-connector:0.1.6
+image: alexellis2/mqtt-connector:0.2.0
 replicas: 1
 
 # Emitter.io example

main.go

@@ -33,7 +33,6 @@ func main() {
 	id := flag.String("id", "testgoid", "The ClientID (optional)")
 	cleansess := flag.Bool("clean", false, "Set Clean Session (default false)")
 	qos := flag.Int("qos", 0, "The Quality of Service 0,1,2 (default 0)")
-	num := flag.Int("num", 1000, "The number of messages to publish or subscribe (default 1)")
 
 	flag.Parse()
 
@@ -98,7 +97,7 @@ func main() {
 		os.Exit(1)
 	}
 
-	for receiveCount < *num {
+	for {
 		incoming := <-choke
 
 		topic := incoming[0]
@@ -117,8 +116,7 @@ func main() {
 		receiveCount++
 	}
 
-	client.Disconnect(250)
-	fmt.Println("Sample Subscriber Disconnected")
+	client.Disconnect(1250)
 }
 
 // ResponseReceiver enables connector to receive results from the