cloud_connector

func HandleControlMessage ¶

func HandleControlMessage(cfg *config.Config, mqttClient MQTT.Client, topicBuilder *mqtt.TopicBuilder, connectionRegistrar connection_repository.ConnectionRegistrar, accountResolver controller.AccountIdResolver, connectedClientRecorder controller.ConnectedClientRecorder, sourcesRecorder controller.SourcesRecorder) func(MQTT.Client, domain.ClientID, string) error

HandleControlMessage returns a function that processes control messages. The returned function should only return an error in the case where the message should get processed again. In other words, if the message processing function returns an error ...do not commit the kafka message.