Package software.amazon.awssdk.aws.greengrass.model

Class MQTTMessage

java.lang.Object
software.amazon.awssdk.aws.greengrass.model.MQTTMessage
All Implemented Interfaces:
EventStreamJsonMessage
public class MQTTMessage extends Object implements EventStreamJsonMessage

  • Field Details

  • Constructor Details

    • MQTTMessage

      public MQTTMessage()

  • Method Details

    • getTopicName

      public String getTopicName()
      The topic to which the message was published.

    • setTopicName

      public void setTopicName(String topicName)
      The topic to which the message was published.

    • withTopicName

      public MQTTMessage withTopicName(String topicName)
      The topic to which the message was published.

    • getPayload

      public byte[] getPayload()
      (Optional) The message payload as a blob.

    • setPayload

      public void setPayload(byte[] payload)
      (Optional) The message payload as a blob.

    • withPayload

      public MQTTMessage withPayload(byte[] payload)
      (Optional) The message payload as a blob.

    • isRetain

      public Boolean isRetain()
      (Optional) The value of the retain flag.

    • setRetain

      public void setRetain(Boolean retain)
      (Optional) The value of the retain flag.

    • withRetain

      public MQTTMessage withRetain(Boolean retain)
      (Optional) The value of the retain flag.

    • getUserProperties

      public List<UserProperty> getUserProperties()
      (Optional) MQTT user properties associated with the message.

    • setUserProperties

      public void setUserProperties(List<UserProperty> userProperties)
      (Optional) MQTT user properties associated with the message.

    • withUserProperties

      public MQTTMessage withUserProperties(List<UserProperty> userProperties)
      (Optional) MQTT user properties associated with the message.

    • getMessageExpiryIntervalSeconds

      public Long getMessageExpiryIntervalSeconds()
      (Optional) Message expiry interval in seconds.

    • setMessageExpiryIntervalSeconds

      public void setMessageExpiryIntervalSeconds(Long messageExpiryIntervalSeconds)
      (Optional) Message expiry interval in seconds.

    • withMessageExpiryIntervalSeconds

      public MQTTMessage withMessageExpiryIntervalSeconds(Long messageExpiryIntervalSeconds)
      (Optional) Message expiry interval in seconds.

    • getCorrelationData

      public byte[] getCorrelationData()
      (Optional) Correlation data blob for request/response.

    • setCorrelationData

      public void setCorrelationData(byte[] correlationData)
      (Optional) Correlation data blob for request/response.

    • withCorrelationData

      public MQTTMessage withCorrelationData(byte[] correlationData)
      (Optional) Correlation data blob for request/response.

    • getResponseTopic

      public String getResponseTopic()
      (Optional) Response topic for request/response.

    • setResponseTopic

      public void setResponseTopic(String responseTopic)
      (Optional) Response topic for request/response.

    • withResponseTopic

      public MQTTMessage withResponseTopic(String responseTopic)
      (Optional) Response topic for request/response.

    • getPayloadFormat

      public PayloadFormat getPayloadFormat()

    • getPayloadFormatAsString

      public String getPayloadFormatAsString()
      (Optional) Message payload format.

    • setPayloadFormat

      public void setPayloadFormat(String payloadFormat)
      (Optional) Message payload format.

    • withPayloadFormat

      public MQTTMessage withPayloadFormat(String payloadFormat)
      (Optional) Message payload format.

    • setPayloadFormat

      public void setPayloadFormat(PayloadFormat payloadFormat)
      (Optional) Message payload format.

    • withPayloadFormat

      public MQTTMessage withPayloadFormat(PayloadFormat payloadFormat)
      (Optional) Message payload format.

    • getContentType

      public String getContentType()
      (Optional) Message content type.

    • setContentType

      public void setContentType(String contentType)
      (Optional) Message content type.

    • withContentType

      public MQTTMessage withContentType(String contentType)
      (Optional) Message content type.

    • getApplicationModelType

      public String getApplicationModelType()
      Description copied from interface: EventStreamJsonMessage
      Returns the named model type. May be used for a header.
      Specified by:
      getApplicationModelType in interface EventStreamJsonMessage
      Returns:
      the named model type

    • equals

      public boolean equals(Object rhs)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object