MCPcopy Create free account
hub / github.com/diffgram/diffgram / broadcast

Method broadcast

shared/database/event/event.py:245–252  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

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,

Callers 1

newMethod · 0.95

Calls 3

serializeMethod · 0.95
send_messageMethod · 0.95
QueueClientClass · 0.90

Tested by

no test coverage detected