Skip to content

Commit

Permalink
add checking err
Browse files Browse the repository at this point in the history
Signed-off-by: Mirko Teodorovic <[email protected]>
  • Loading branch information
mteodor committed Feb 6, 2020
1 parent 31f2a26 commit 6db736d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions internal/pkg/mqtt/sub.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,12 +117,12 @@ func (b *broker) handleMsg(mc paho.Client, msg paho.Message) {
b.logger.Warn(fmt.Sprintf("Execute operation failed: %s", err))
}
case config:
b.logger.Info(fmt.Sprintf("Execute command for uuid %s and command string %s", uuid, cmdStr))
b.logger.Info(fmt.Sprintf("Config service for uuid %s and command string %s", uuid, cmdStr))
if err := b.svc.ServiceConfig(uuid, cmdStr); err != nil {
b.logger.Warn(fmt.Sprintf("Execute operation failed: %s", err))
}
case service:
b.logger.Info(fmt.Sprintf("Execute command for uuid %s and command string %s", uuid, cmdStr))
b.logger.Info(fmt.Sprintf("List services for uuid %s and command string %s", uuid, cmdStr))
if err := b.svc.ServiceConfig(uuid, cmdStr); err != nil {
b.logger.Warn(fmt.Sprintf("Execute operation failed: %s", err))
}
Expand Down

0 comments on commit 6db736d

Please sign in to comment.