in awsiot/greengrasscoreipc/model.py [0:0]
def _to_payload(self):
payload = {}
if self.topic_name is not None:
payload['topicName'] = self.topic_name
if self.qos is not None:
payload['qos'] = self.qos
if self.payload is not None:
payload['payload'] = base64.b64encode(self.payload).decode()
if self.retain is not None:
payload['retain'] = self.retain
if self.user_properties is not None:
payload['userProperties'] = [i._to_payload() for i in self.user_properties]
if self.message_expiry_interval_seconds is not None:
payload['messageExpiryIntervalSeconds'] = self.message_expiry_interval_seconds
if self.correlation_data is not None:
payload['correlationData'] = base64.b64encode(self.correlation_data).decode()
if self.response_topic is not None:
payload['responseTopic'] = self.response_topic
if self.payload_format is not None:
payload['payloadFormat'] = self.payload_format
if self.content_type is not None:
payload['contentType'] = self.content_type
return payload