(self, client)
| 160 | t.start() |
| 161 | |
| 162 | def handle(self, client): |
| 163 | itrans = self.inputTransportFactory.getTransport(client) |
| 164 | otrans = self.outputTransportFactory.getTransport(client) |
| 165 | iprot = self.inputProtocolFactory.getProtocol(itrans) |
| 166 | oprot = self.outputProtocolFactory.getProtocol(otrans) |
| 167 | try: |
| 168 | while not self.is_shutdown: |
| 169 | self.processor.process(iprot, oprot) |
| 170 | except TTransport.TTransportException: |
| 171 | pass |
| 172 | except Exception as x: |
| 173 | print(x) |
| 174 | |
| 175 | itrans.close() |
| 176 | otrans.close() |
| 177 | |
| 178 | |
| 179 | class StatestoreSubscriber(object): |
nothing calls this directly
no test coverage detected