message-event

Description

class MessageEvent(BaseKafkaModel):
    _topic = 'message_events'
 
    def __init__(self, channel_id: int, initiator_id: int, timestamp: int = None,
                 message_id: int = None, example_id: str = None, example_compounded_id: str = None,
                 pool_id: int = None, campaign_id: int = None, sent_count: int = None,
                 firebase_id: int = None, sender_id: int = None, **kwargs):
        super(MessageEvent, self).__init__(**kwargs)
        self.channel_id = channel_id
        self.initiator_id = initiator_id
        self.sent_count = sent_count or 0
        self.campaign_id = campaign_id or 0
        self.pool_id = pool_id or 0
        self.example_id = str(example_id) if example_id else '0'
        self.example_compounded_id = example_compounded_id or ''
        self.message_id = message_id or 0
        self.firebase_id = firebase_id or 0
        self.sender_id = sender_id or 0
        self.timestamp = timestamp or int(time.time())

Links

• producers:

• consumers: