go fmt
This commit is contained in:
parent
001fb31173
commit
40fc5bc2ad
|
|
@ -85,10 +85,10 @@ func consumer(args []string) {
|
|||
total := time.Tick(time.Second * 5)
|
||||
for {
|
||||
select {
|
||||
case <- throughput:
|
||||
log.Printf("throughput: %d msgs/s\n", count - throughputCount)
|
||||
case <-throughput:
|
||||
log.Printf("throughput: %d msgs/s\n", count-throughputCount)
|
||||
throughputCount = count
|
||||
case <- total:
|
||||
case <-total:
|
||||
log.Printf("total: %d\n", count)
|
||||
}
|
||||
}
|
||||
|
|
@ -96,7 +96,7 @@ func consumer(args []string) {
|
|||
|
||||
for stanza := range x.In {
|
||||
if _, ok := stanza.(*xmpp.Message); ok {
|
||||
count ++
|
||||
count++
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue