(self)
| 348 | self.connection_factory = connection_factory |
| 349 | |
| 350 | def try_reconnect(self): |
| 351 | return self.connection_factory() |
| 352 | |
| 353 | def on_reconnection(self, connection): |
| 354 | log.info("Successful reconnection to %s, marking node up if it isn't already", self.host) |
nothing calls this directly
no test coverage detected