Remove Queue Breaks
This commit is contained in:
parent
5ef2f6f94c
commit
4856ca665b
|
@ -190,7 +190,6 @@ func (cr *contactRetry) run() {
|
|||
if contact.state == connections.DISCONNECTED {
|
||||
cr.publishConnectionRequest(contact)
|
||||
connectingCount++
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -203,7 +202,6 @@ func (cr *contactRetry) run() {
|
|||
if contact.state == connections.DISCONNECTED {
|
||||
cr.publishConnectionRequest(contact)
|
||||
connectingCount++
|
||||
break
|
||||
}
|
||||
}
|
||||
cr.lastCheck = time.Now()
|
||||
|
|
Loading…
Reference in New Issue