(self, connection)
| 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) |
| 355 | if self.is_host_addition: |
| 356 | self.on_add(self.host) |
| 357 | else: |
| 358 | self.on_up(self.host) |
| 359 | |
| 360 | def on_exception(self, exc, next_delay): |
| 361 | if isinstance(exc, AuthenticationFailed): |