(self)
| 243 | t.start() |
| 244 | |
| 245 | def broadcast(self): |
| 246 | if settings.DIFFGRAM_SYSTEM_MODE == 'testing': |
| 247 | return |
| 248 | queue_mngr = QueueClient() |
| 249 | message = self.serialize() |
| 250 | queue_mngr.send_message(message = message, |
| 251 | routing_key = RoutingKeys.event_new.value, |
| 252 | exchange = Exchanges.events.value) |
| 253 | @staticmethod |
| 254 | def new(session, |
| 255 | kind = None, |
no test coverage detected