dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Better logging for MQTT consumer 

closes #1023
closes #921
This commit is contained in:
chaton78 2016-04-13 23:06:30 -04:00 committed by Cameron Sparr
parent 8ec8ae0587
commit 93f57edd3a
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
CHANGELOG.md
View File

@ -2,7 +2,7 @@
### Release Notes ### Release Notes
- `tagexclude` and `tagexclude` are now available, which can be used to remove - `tagexclude` and `tagexclude` are now available, which can be used to remove
tags from measurements on inputs and outputs. See tags from measurements on inputs and outputs. See
[the configuration doc](https://github.com/influxdata/telegraf/blob/master/docs/CONFIGURATION.md) [the configuration doc](https://github.com/influxdata/telegraf/blob/master/docs/CONFIGURATION.md)
for more details. for more details.
- **Measurement filtering:** All measurement filters now match based on glob - **Measurement filtering:** All measurement filters now match based on glob
@ -14,6 +14,7 @@ based on _prefix_ in addition to globs. This means that a filter like
- [#1017](https://github.com/influxdata/telegraf/pull/1017): taginclude and tagexclude arguments. - [#1017](https://github.com/influxdata/telegraf/pull/1017): taginclude and tagexclude arguments.
### Bugfixes ### Bugfixes
- [#921](https://github.com/influxdata/telegraf/pull/921): mqtt_consumer stops gathering metrics. Thanks @chaton78!
## v0.12.1 [2016-04-14] ## v0.12.1 [2016-04-14]

3
plugins/inputs/mqtt_consumer/mqtt_consumer.go
View File

@ -133,6 +133,7 @@ func (m *MQTTConsumer) Start(acc telegraf.Accumulator) error {
return nil return nil
} }
func (m *MQTTConsumer) onConnect(c mqtt.Client) { func (m *MQTTConsumer) onConnect(c mqtt.Client) {
log.Printf("MQTT Client Connected")
if !m.PersistentSession || !m.started { if !m.PersistentSession || !m.started {
topics := make(map[string]byte) topics := make(map[string]byte)
for _, topic := range m.Topics { for _, topic := range m.Topics {
@ -150,7 +151,7 @@ func (m *MQTTConsumer) onConnect(c mqtt.Client) {
} }
func (m *MQTTConsumer) onConnectionLost(c mqtt.Client, err error) { func (m *MQTTConsumer) onConnectionLost(c mqtt.Client, err error) {
log.Printf("MQTT Connection lost\nerror: %s\nClient should retry to reconnect", err.Error()) log.Printf("MQTT Connection lost\nerror: %s\nMQTT Client will try to reconnect", err.Error())
return return
} }