com.amazonaws.greengrass.streammanager.model

Class Message

java.lang.Object

com.amazonaws.greengrass.streammanager.model.Message

public class Message
extends Object

Message object containing metadata and the user's payload.

Constructor Summary

Constructors

Constructor and Description
Message() No args constructor for use in serialization
Message(String streamName, Long sequenceNumber, Long ingestTime, byte[] payload)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Long	getIngestTime() The time that the message was ingested to Stream Manager.
byte[]	getPayload() The binary message data.
Long	getSequenceNumber() The sequence number of this message within the stream.
String	getStreamName() The name of the stream which this message is in.
int	hashCode()
void	setIngestTime(Long ingestTime) The time that the message was ingested to Stream Manager.
void	setPayload(byte[] payload) The binary message data.
void	setSequenceNumber(Long sequenceNumber) The sequence number of this message within the stream.
void	setStreamName(String streamName) The name of the stream which this message is in.
String	toString()
Message	withIngestTime(Long ingestTime)
Message	withPayload(byte[] payload)
Message	withSequenceNumber(Long sequenceNumber)
Message	withStreamName(String streamName)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Message

public Message()

No args constructor for use in serialization

Message

public Message(String streamName,
               Long sequenceNumber,
               Long ingestTime,
               byte[] payload)

Parameters:

sequenceNumber -

payload -

ingestTime -

streamName -

Method Detail

getStreamName

public String getStreamName()

The name of the stream which this message is in. (Required)

setStreamName

public void setStreamName(String streamName)

The name of the stream which this message is in. (Required)

withStreamName

public Message withStreamName(String streamName)

getSequenceNumber

public Long getSequenceNumber()

The sequence number of this message within the stream.

setSequenceNumber

public void setSequenceNumber(Long sequenceNumber)

The sequence number of this message within the stream.

withSequenceNumber

public Message withSequenceNumber(Long sequenceNumber)

getIngestTime

public Long getIngestTime()

The time that the message was ingested to Stream Manager. Data is Unix epoch time in milliseconds.

setIngestTime

public void setIngestTime(Long ingestTime)

The time that the message was ingested to Stream Manager. Data is Unix epoch time in milliseconds.

withIngestTime

public Message withIngestTime(Long ingestTime)

getPayload

public byte[] getPayload()

The binary message data. (Required)

setPayload

public void setPayload(byte[] payload)

The binary message data. (Required)

withPayload

public Message withPayload(byte[] payload)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object