com.amazonaws.greengrass.javasdk.model

Class PublishRequest

java.lang.Object

com.amazonaws.greengrass.javasdk.model.PublishRequest

public class PublishRequest
extends Object

Request for publish message to a topic.

Constructor Summary

Constructors

Constructor and Description
PublishRequest()

Method Summary

Modifier and Type	Method and Description
ByteBuffer	getPayload() Getter for the payload.
QueueFullPolicy	getQueueFullPolicy() Getter for the queueFullPolicy.
String	getTopic() Getter for the topic.
void	setPayload(ByteBuffer payload) Setter for the payload.
void	setQueueFullPolicy(QueueFullPolicy queueFullPolicy) Setter for the queueFullPolicy.
void	setTopic(String topic) Setter for the topic.
PublishRequest	withPayload(ByteBuffer p) Generate the request with payload.
PublishRequest	withQueueFullPolicy(QueueFullPolicy q) Generate the request with queueFullPolicy.
PublishRequest	withTopic(String t) Generate the request for a topic.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PublishRequest

public PublishRequest()

Method Detail

getTopic

public String getTopic()

Getter for the topic.

Returns:

the name of the topic

setTopic

public void setTopic(String topic)

Setter for the topic.

Parameters:

topic - the name of the topic

getPayload

public ByteBuffer getPayload()

Getter for the payload. Warning: ByteBuffers returned by the SDK are mutable. Changes to the content of the byte buffer will be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer.

Returns:

the payload byte buffer

setPayload

public void setPayload(ByteBuffer payload)

Setter for the payload. Warning: ByteBuffers returned by the SDK are mutable. Changes to the content of the byte buffer will be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer.

Parameters:

payload - the payload bytes

getQueueFullPolicy

public QueueFullPolicy getQueueFullPolicy()

Getter for the queueFullPolicy.

Returns:

value of queueFullPolicy

setQueueFullPolicy

public void setQueueFullPolicy(QueueFullPolicy queueFullPolicy)

Setter for the queueFullPolicy.

Parameters:

queueFullPolicy - value of queueFullPolicy

withTopic

public PublishRequest withTopic(String t)

Generate the request for a topic.

Parameters:

t - the name of the topic

Returns:

the publish request with topic specified

withPayload

public PublishRequest withPayload(ByteBuffer p)

Generate the request with payload. Warning: ByteBuffers returned by the SDK are mutable. Changes to the content of the byte buffer will be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer.

Parameters:

p - the payload bytes

Returns:

the publish request with payload specified

withQueueFullPolicy

public PublishRequest withQueueFullPolicy(QueueFullPolicy q)

Generate the request with queueFullPolicy.

Parameters:

q - the queueFullPolicy type

Returns:

the publish request with queueFullPolicy specified