Description
class MessageInitiatorResponse(BaseKafkaModel):
_topic = 'message_responses'
def __init__(self, channel_id: int, initiator_id: int, sent: int, failed: int,
campaign_task_id: str = None, campaign_id: int = None, segment_id: int = None,
sender_group_token: str = None, timestamp: int = None, **kwargs):
super(MessageInitiatorResponse, self).__init__(**kwargs)
self.channel_id = channel_id
self.initiator_id = initiator_id
self.sent = sent
self.failed = failed
self.campaign_id = campaign_id or 0
self.segment_id = segment_id or 0
self.campaign_task_id = campaign_task_id or ''
self.sender_group_token = sender_group_token or ''
self.timestamp = timestamp or int(time.time())