@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class PublishRequest extends AmazonWebServiceRequest implements Serializable, Cloneable
The input for the Publish operation.
NOOP
Constructor and Description |
---|
PublishRequest() |
Modifier and Type | Method and Description |
---|---|
PublishRequest |
clone()
Creates a shallow clone of this object for all fields except the handler context.
|
boolean |
equals(Object obj) |
String |
getContentType()
A UTF-8 encoded string that describes the content of the publishing message.
|
String |
getCorrelationData()
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received.
|
Long |
getMessageExpiry()
A user-defined integer value that represents the message expiry interval in seconds.
|
ByteBuffer |
getPayload()
The message body.
|
String |
getPayloadFormatIndicator()
An
Enum string value that indicates whether the payload is formatted as UTF-8. |
Integer |
getQos()
The Quality of Service (QoS) level.
|
String |
getResponseTopic()
A UTF-8 encoded string that's used as the topic name for a response message.
|
Boolean |
getRetain()
A Boolean value that determines whether to set the RETAIN flag when the message is published.
|
String |
getTopic()
The name of the MQTT topic.
|
String |
getUserProperties()
A JSON string that contains an array of JSON objects.
|
int |
hashCode() |
Boolean |
isRetain()
A Boolean value that determines whether to set the RETAIN flag when the message is published.
|
void |
setContentType(String contentType)
A UTF-8 encoded string that describes the content of the publishing message.
|
void |
setCorrelationData(String correlationData)
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received.
|
void |
setMessageExpiry(Long messageExpiry)
A user-defined integer value that represents the message expiry interval in seconds.
|
void |
setPayload(ByteBuffer payload)
The message body.
|
void |
setPayloadFormatIndicator(String payloadFormatIndicator)
An
Enum string value that indicates whether the payload is formatted as UTF-8. |
void |
setQos(Integer qos)
The Quality of Service (QoS) level.
|
void |
setResponseTopic(String responseTopic)
A UTF-8 encoded string that's used as the topic name for a response message.
|
void |
setRetain(Boolean retain)
A Boolean value that determines whether to set the RETAIN flag when the message is published.
|
void |
setTopic(String topic)
The name of the MQTT topic.
|
void |
setUserProperties(String userProperties)
A JSON string that contains an array of JSON objects.
|
String |
toString()
Returns a string representation of this object.
|
PublishRequest |
withContentType(String contentType)
A UTF-8 encoded string that describes the content of the publishing message.
|
PublishRequest |
withCorrelationData(String correlationData)
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received.
|
PublishRequest |
withMessageExpiry(Long messageExpiry)
A user-defined integer value that represents the message expiry interval in seconds.
|
PublishRequest |
withPayload(ByteBuffer payload)
The message body.
|
PublishRequest |
withPayloadFormatIndicator(PayloadFormatIndicator payloadFormatIndicator)
An
Enum string value that indicates whether the payload is formatted as UTF-8. |
PublishRequest |
withPayloadFormatIndicator(String payloadFormatIndicator)
An
Enum string value that indicates whether the payload is formatted as UTF-8. |
PublishRequest |
withQos(Integer qos)
The Quality of Service (QoS) level.
|
PublishRequest |
withResponseTopic(String responseTopic)
A UTF-8 encoded string that's used as the topic name for a response message.
|
PublishRequest |
withRetain(Boolean retain)
A Boolean value that determines whether to set the RETAIN flag when the message is published.
|
PublishRequest |
withTopic(String topic)
The name of the MQTT topic.
|
PublishRequest |
withUserProperties(String userProperties)
A JSON string that contains an array of JSON objects.
|
addHandlerContext, getCloneRoot, getCloneSource, getCustomQueryParameters, getCustomRequestHeaders, getGeneralProgressListener, getHandlerContext, getReadLimit, getRequestClientOptions, getRequestCredentials, getRequestCredentialsProvider, getRequestMetricCollector, getSdkClientExecutionTimeout, getSdkRequestTimeout, putCustomQueryParameter, putCustomRequestHeader, setGeneralProgressListener, setRequestCredentials, setRequestCredentialsProvider, setRequestMetricCollector, setSdkClientExecutionTimeout, setSdkRequestTimeout, withGeneralProgressListener, withRequestCredentialsProvider, withRequestMetricCollector, withSdkClientExecutionTimeout, withSdkRequestTimeout
public void setTopic(String topic)
The name of the MQTT topic.
topic
- The name of the MQTT topic.public String getTopic()
The name of the MQTT topic.
public PublishRequest withTopic(String topic)
The name of the MQTT topic.
topic
- The name of the MQTT topic.public void setQos(Integer qos)
The Quality of Service (QoS) level. The default QoS level is 0.
qos
- The Quality of Service (QoS) level. The default QoS level is 0.public Integer getQos()
The Quality of Service (QoS) level. The default QoS level is 0.
public PublishRequest withQos(Integer qos)
The Quality of Service (QoS) level. The default QoS level is 0.
qos
- The Quality of Service (QoS) level. The default QoS level is 0.public void setRetain(Boolean retain)
A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
retain
- A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
public Boolean getRetain()
A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
public PublishRequest withRetain(Boolean retain)
A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
retain
- A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
public Boolean isRetain()
A Boolean value that determines whether to set the RETAIN flag when the message is published.
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
Setting the RETAIN flag causes the message to be retained and sent to new subscribers to the topic.
Valid values: true
| false
Default value: false
public void setPayload(ByteBuffer payload)
The message body. MQTT accepts text, binary, and empty (null) message payloads.
Publishing an empty (null) payload with retain = true
deletes the retained message identified
by topic from Amazon Web Services IoT Core.
The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. Users of the SDK should not perform Base64 encoding on this field.
Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future major version of the SDK.
payload
- The message body. MQTT accepts text, binary, and empty (null) message payloads.
Publishing an empty (null) payload with retain = true
deletes the retained message
identified by topic from Amazon Web Services IoT Core.
public ByteBuffer getPayload()
The message body. MQTT accepts text, binary, and empty (null) message payloads.
Publishing an empty (null) payload with retain = true
deletes the retained message identified
by topic from Amazon Web Services IoT Core.
ByteBuffer
s are stateful. Calling their get
methods changes their position
. We recommend
using ByteBuffer.asReadOnlyBuffer()
to create a read-only view of the buffer with an independent
position
, and calling get
methods on this rather than directly on the returned ByteBuffer
.
Doing so will ensure that anyone else using the ByteBuffer
will not be affected by changes to the
position
.
Publishing an empty (null) payload with retain = true
deletes the retained message
identified by topic from Amazon Web Services IoT Core.
public PublishRequest withPayload(ByteBuffer payload)
The message body. MQTT accepts text, binary, and empty (null) message payloads.
Publishing an empty (null) payload with retain = true
deletes the retained message identified
by topic from Amazon Web Services IoT Core.
The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. Users of the SDK should not perform Base64 encoding on this field.
Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future major version of the SDK.
payload
- The message body. MQTT accepts text, binary, and empty (null) message payloads.
Publishing an empty (null) payload with retain = true
deletes the retained message
identified by topic from Amazon Web Services IoT Core.
public void setUserProperties(String userProperties)
A JSON string that contains an array of JSON objects. If you don’t use Amazon Web Services SDK or CLI, you must
encode the JSON string to base64 format before adding it to the HTTP header. userProperties
is an
HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
This field's value must be valid JSON according to RFC 7159, including the opening and closing braces. For example: '{"key": "value"}'.
The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. Users of the SDK should not perform Base64 encoding on this field.
userProperties
- A JSON string that contains an array of JSON objects. If you don’t use Amazon Web Services SDK or CLI, you
must encode the JSON string to base64 format before adding it to the HTTP header.
userProperties
is an HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
public String getUserProperties()
A JSON string that contains an array of JSON objects. If you don’t use Amazon Web Services SDK or CLI, you must
encode the JSON string to base64 format before adding it to the HTTP header. userProperties
is an
HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
This field's value will be valid JSON according to RFC 7159, including the opening and closing braces. For example: '{"key": "value"}'.
userProperties
is an HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
public PublishRequest withUserProperties(String userProperties)
A JSON string that contains an array of JSON objects. If you don’t use Amazon Web Services SDK or CLI, you must
encode the JSON string to base64 format before adding it to the HTTP header. userProperties
is an
HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
This field's value must be valid JSON according to RFC 7159, including the opening and closing braces. For example: '{"key": "value"}'.
The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. Users of the SDK should not perform Base64 encoding on this field.
userProperties
- A JSON string that contains an array of JSON objects. If you don’t use Amazon Web Services SDK or CLI, you
must encode the JSON string to base64 format before adding it to the HTTP header.
userProperties
is an HTTP header value in the API.
The following example userProperties
parameter is a JSON string which represents two User
Properties. Note that it needs to be base64-encoded:
[{"deviceName": "alpha"}, {"deviceCnt": "45"}]
public void setPayloadFormatIndicator(String payloadFormatIndicator)
An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.
payloadFormatIndicator
- An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.PayloadFormatIndicator
public String getPayloadFormatIndicator()
An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.
Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.PayloadFormatIndicator
public PublishRequest withPayloadFormatIndicator(String payloadFormatIndicator)
An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.
payloadFormatIndicator
- An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.PayloadFormatIndicator
public PublishRequest withPayloadFormatIndicator(PayloadFormatIndicator payloadFormatIndicator)
An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.
payloadFormatIndicator
- An Enum
string value that indicates whether the payload is formatted as UTF-8.
payloadFormatIndicator
is an HTTP header value in the API.PayloadFormatIndicator
public void setContentType(String contentType)
A UTF-8 encoded string that describes the content of the publishing message.
contentType
- A UTF-8 encoded string that describes the content of the publishing message.public String getContentType()
A UTF-8 encoded string that describes the content of the publishing message.
public PublishRequest withContentType(String contentType)
A UTF-8 encoded string that describes the content of the publishing message.
contentType
- A UTF-8 encoded string that describes the content of the publishing message.public void setResponseTopic(String responseTopic)
A UTF-8 encoded string that's used as the topic name for a response message. The response topic is used to describe the topic which the receiver should publish to as part of the request-response flow. The topic must not contain wildcard characters.
responseTopic
- A UTF-8 encoded string that's used as the topic name for a response message. The response topic is used to
describe the topic which the receiver should publish to as part of the request-response flow. The topic
must not contain wildcard characters.public String getResponseTopic()
A UTF-8 encoded string that's used as the topic name for a response message. The response topic is used to describe the topic which the receiver should publish to as part of the request-response flow. The topic must not contain wildcard characters.
public PublishRequest withResponseTopic(String responseTopic)
A UTF-8 encoded string that's used as the topic name for a response message. The response topic is used to describe the topic which the receiver should publish to as part of the request-response flow. The topic must not contain wildcard characters.
responseTopic
- A UTF-8 encoded string that's used as the topic name for a response message. The response topic is used to
describe the topic which the receiver should publish to as part of the request-response flow. The topic
must not contain wildcard characters.public void setCorrelationData(String correlationData)
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received. correlationData
is an HTTP header value in the API.
correlationData
- The base64-encoded binary data used by the sender of the request message to identify which request the
response message is for when it's received. correlationData
is an HTTP header value in the
API.public String getCorrelationData()
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received. correlationData
is an HTTP header value in the API.
correlationData
is an HTTP header value in the
API.public PublishRequest withCorrelationData(String correlationData)
The base64-encoded binary data used by the sender of the request message to identify which request the response
message is for when it's received. correlationData
is an HTTP header value in the API.
correlationData
- The base64-encoded binary data used by the sender of the request message to identify which request the
response message is for when it's received. correlationData
is an HTTP header value in the
API.public void setMessageExpiry(Long messageExpiry)
A user-defined integer value that represents the message expiry interval in seconds. If absent, the message
doesn't expire. For more information about the limits of messageExpiry
, see Amazon Web Services IoT
Core message broker and protocol limits and quotas from the Amazon Web Services Reference Guide.
messageExpiry
- A user-defined integer value that represents the message expiry interval in seconds. If absent, the
message doesn't expire. For more information about the limits of messageExpiry
, see Amazon Web
Services IoT Core message broker and protocol limits and quotas from the Amazon Web Services
Reference Guide.public Long getMessageExpiry()
A user-defined integer value that represents the message expiry interval in seconds. If absent, the message
doesn't expire. For more information about the limits of messageExpiry
, see Amazon Web Services IoT
Core message broker and protocol limits and quotas from the Amazon Web Services Reference Guide.
messageExpiry
, see Amazon Web
Services IoT Core message broker and protocol limits and quotas from the Amazon Web Services
Reference Guide.public PublishRequest withMessageExpiry(Long messageExpiry)
A user-defined integer value that represents the message expiry interval in seconds. If absent, the message
doesn't expire. For more information about the limits of messageExpiry
, see Amazon Web Services IoT
Core message broker and protocol limits and quotas from the Amazon Web Services Reference Guide.
messageExpiry
- A user-defined integer value that represents the message expiry interval in seconds. If absent, the
message doesn't expire. For more information about the limits of messageExpiry
, see Amazon Web
Services IoT Core message broker and protocol limits and quotas from the Amazon Web Services
Reference Guide.public String toString()
toString
in class Object
Object.toString()
public PublishRequest clone()
AmazonWebServiceRequest
clone
in class AmazonWebServiceRequest
Object.clone()