Class MQTTMessage

    • Constructor Detail

      • MQTTMessage

        public MQTTMessage()
    • Method Detail

      • 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.
      • 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.
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object