wn/universal-data-ingest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

missing handler handling

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2023-11-27 15:41:27 +01:00
parent a862b4bc2d
commit bf71cd1766
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/udi/dispatcher/dispatcher.go
View File

@ -27,7 +27,7 @@ func InputDispatcher() {
for { for {
select { select {
case message := <- mqtt.InputChannel: case message := <- mqtt.InputChannel:
log.Printf("Message arrived in inputDispatcher, topic: %s, payload: %s\n", message.Topic, message.Payload) log.Printf("Message arrived in inputDispatcher, topic: %s\n", message.Topic)
for _, mapping := range config.Config.TopicMappings { for _, mapping := range config.Config.TopicMappings {
log.Printf("Testing %s -> %s", mapping.Topics, mapping.Handler) log.Printf("Testing %s -> %s", mapping.Topics, mapping.Handler)
@ -35,8 +35,12 @@ func InputDispatcher() {
log.Printf("Testing %s in %s", message.Topic, subscribedTopic) log.Printf("Testing %s in %s", message.Topic, subscribedTopic)
if mqtt.TopicMatchesSubscription(message.Topic, subscribedTopic) { if mqtt.TopicMatchesSubscription(message.Topic, subscribedTopic) {
log.Printf("Handle message in handler %s", mapping.Handler) log.Printf("Handle message in handler %s", mapping.Handler)
handler := handlerMap[mapping.Handler] handler, exists := handlerMap[mapping.Handler]
handler.Handle(message.Topic, string(message.Payload)) if exists {
handler.Handle(message.Topic, string(message.Payload))
} else {
log.Printf("Handler not found, message is lost")
}
} else { } else {
log.Printf("no match") log.Printf("no match")
} }