cloud_connector

Documentation

Index

• func HandleControlMessage(cfg *config.Config, mqttClient MQTT.Client, topicBuilder *mqtt.TopicBuilder, ...) func(MQTT.Client, domain.ClientID, string) error

Functions

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.