(self)
| 428 | self.set_configuration_option("client_identifier", tests.common.current_node) |
| 429 | |
| 430 | def connect(self): |
| 431 | try: |
| 432 | self.__beeswax_client.connect() |
| 433 | self.log_client("connected to %s with beeswax" % self.__host_port) |
| 434 | except Exception as e: |
| 435 | self.log_client("failed connecting to %s with beeswax" % self.__host_port) |
| 436 | raise e |
| 437 | |
| 438 | # TODO: rename to close_connection |
| 439 | def close(self): |
nothing calls this directly
no test coverage detected