(self)
| 49 | self.mongo_collection = mongo_collection |
| 50 | |
| 51 | def start(self): |
| 52 | def _go(): |
| 53 | self._connect() |
| 54 | self._listen() |
| 55 | self._disconnect() |
| 56 | |
| 57 | self.stop = False |
| 58 | self.on_open() |
| 59 | self.thread = Thread(target=_go) |
| 60 | self.keepalive = Thread(target=self._keepalive) |
| 61 | self.thread.start() |
| 62 | |
| 63 | def _connect(self): |
| 64 | if self.products is None: |
no test coverage detected