Skip to content

Commit

Permalink
formatted code
Browse files Browse the repository at this point in the history
  • Loading branch information
jvrahav committed May 3, 2018
1 parent df6fea7 commit 821f5c6
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions plugins/outputs/mqtt/mqtt.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,15 +47,15 @@ var sampleConfig = `
`

type MQTT struct {
Servers []string `toml:"servers"`
Username string
Password string
Database string
Timeout internal.Duration
TopicPrefix string
QoS int `toml:"qos"`
ClientID string `toml:"client_id"`
BatchMessage bool `toml:"batch"`
Servers []string `toml:"servers"`
Username string
Password string
Database string
Timeout internal.Duration
TopicPrefix string
QoS int `toml:"qos"`
ClientID string `toml:"client_id"`
BatchMessage bool `toml:"batch"`

// Path to CA file
SSLCA string `toml:"ssl_ca"`
Expand Down Expand Up @@ -144,7 +144,7 @@ func (m *MQTT) Write(metrics []telegraf.Metric) error {
return err
}

if (m.BatchMessage) {
if m.BatchMessage {
metricsmap[topic] = append(metricsmap[topic], buf...)
} else {
err = m.publish(topic, buf)
Expand Down

0 comments on commit 821f5c6

Please sign in to comment.