Greengrass IPC update including MQTT 5 models (#446)

Author: MikeDombo

awsiot/greengrasscoreipc/clientv2.py

@@ -511,30 +511,58 @@ def pause_component_async(self, *,
  def publish_to_iot_core(self, *,
  topic_name: typing.Optional[str] = None,
  qos: typing.Optional[str] = None,
- payload: typing.Optional[typing.Union[bytes, str]] = None) -> model.PublishToIoTCoreResponse:
+ payload: typing.Optional[typing.Union[bytes, str]] = None,
+ retain: typing.Optional[bool] = None,
+ user_properties: typing.Optional[typing.List[model.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) -> model.PublishToIoTCoreResponse:
  """
  Perform the PublishToIoTCore operation synchronously.
 
  Args:
  topic_name: 
  qos: QOS enum value
  payload: 
+ retain: 
+ user_properties: 
+ message_expiry_interval_seconds: 
+ correlation_data: 
+ response_topic: 
+ payload_format: PayloadFormat enum value
+ content_type: 
  """
- return self.publish_to_iot_core_async(topic_name=topic_name, qos=qos, payload=payload).result()
+ return self.publish_to_iot_core_async(topic_name=topic_name, qos=qos, payload=payload, retain=retain, user_properties=user_properties, message_expiry_interval_seconds=message_expiry_interval_seconds, correlation_data=correlation_data, response_topic=response_topic, payload_format=payload_format, content_type=content_type).result()
 
  def publish_to_iot_core_async(self, *,
  topic_name: typing.Optional[str] = None,
  qos: typing.Optional[str] = None,
- payload: typing.Optional[typing.Union[bytes, str]] = None): # type: (...) -> concurrent.futures.Future[model.PublishToIoTCoreResponse]
+ payload: typing.Optional[typing.Union[bytes, str]] = None,
+ retain: typing.Optional[bool] = None,
+ user_properties: typing.Optional[typing.List[model.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): # type: (...) -> concurrent.futures.Future[model.PublishToIoTCoreResponse]
  """
  Perform the PublishToIoTCore operation asynchronously.
 
  Args:
  topic_name: 
  qos: QOS enum value
  payload: 
- """
- request = model.PublishToIoTCoreRequest(topic_name=topic_name, qos=qos, payload=payload)
+ retain: 
+ user_properties: 
+ message_expiry_interval_seconds: 
+ correlation_data: 
+ response_topic: 
+ payload_format: PayloadFormat enum value
+ content_type: 
+ """
+ request = model.PublishToIoTCoreRequest(topic_name=topic_name, qos=qos, payload=payload, retain=retain, user_properties=user_properties, message_expiry_interval_seconds=message_expiry_interval_seconds, correlation_data=correlation_data, response_topic=response_topic, payload_format=payload_format, content_type=content_type)
  operation = self.client.new_publish_to_iot_core()
  write_future = operation.activate(request)
  return self.__combine_futures(write_future, operation.get_response())