Matthieu Lalonde 5 years ago
parent d65ae5c840
commit 9574dc10b6

@ -221,6 +221,7 @@ func (b *Type) periodicTicker() {
log.Println("Checking for conversations") log.Println("Checking for conversations")
pm, _ := b.avr.FetchPendingConversations() pm, _ := b.avr.FetchPendingConversations()
if len(pm) > 0 { if len(pm) > 0 {
log.Printf("Found %d new messages\n", len(pm))
b.handleNewPendingConversation(pm) b.handleNewPendingConversation(pm)
} }
checkConversations.Reset(tickerIntervalCheckIncomingConversations * time.Minute) checkConversations.Reset(tickerIntervalCheckIncomingConversations * time.Minute)

Loading…
Cancel
Save