in awsiot/greengrasscoreipc/model.py [0:0]
def __init__(self, *,
topic_name: typing.Optional[str] = None,
qos: typing.Optional[str] = None,
payload: typing.Optional[typing.Union[bytes, str]] = None,
retain: typing.Optional[bool] = None,
user_properties: typing.Optional[typing.List[UserProperty]] = None,
message_expiry_interval_seconds: typing.Optional[int] = None,
correlation_data: typing.Optional[typing.Union[bytes, str]] = None,
response_topic: typing.Optional[str] = None,
payload_format: typing.Optional[str] = None,
content_type: typing.Optional[str] = None):
super().__init__()
self.topic_name = topic_name # type: typing.Optional[str]
self.qos = qos # type: typing.Optional[str]
if payload is not None and isinstance(payload, str):
payload = payload.encode('utf-8')
self.payload = payload # type: typing.Optional[bytes]
self.retain = retain # type: typing.Optional[bool]
self.user_properties = user_properties # type: typing.Optional[typing.List[UserProperty]]
self.message_expiry_interval_seconds = message_expiry_interval_seconds # type: typing.Optional[int]
if correlation_data is not None and isinstance(correlation_data, str):
correlation_data = correlation_data.encode('utf-8')
self.correlation_data = correlation_data # type: typing.Optional[bytes]
self.response_topic = response_topic # type: typing.Optional[str]
self.payload_format = payload_format # type: typing.Optional[str]
self.content_type = content_type # type: typing.Optional[str]