Class StreamMessageProperties

java.lang.Object

org.springframework.amqp.core.MessageProperties

org.springframework.rabbit.stream.support.StreamMessageProperties

All Implemented Interfaces:

Serializable

public class StreamMessageProperties
extends MessageProperties

MessageProperties extension for stream messages.

Since:

2.4

Author:

Gary Russell

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.springframework.amqp.core.MessageProperties

BATCH_FORMAT_LENGTH_HEADER4, CONTENT_TYPE_BYTES, CONTENT_TYPE_JSON, CONTENT_TYPE_JSON_ALT, CONTENT_TYPE_SERIALIZED_OBJECT, CONTENT_TYPE_TEXT_PLAIN, CONTENT_TYPE_XML, DEFAULT_CONTENT_TYPE, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, RETRY_COUNT, SPRING_AUTO_DECOMPRESS, SPRING_BATCH_FORMAT, X_DELAY, X_DELAY_MAX

Constructor Summary

Constructors

Constructor	Description
StreamMessageProperties()	Create a new instance.
StreamMessageProperties(@Nullable com.rabbitmq.stream.MessageHandler.Context context)	Create a new instance with the provided context.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
@Nullable com.rabbitmq.stream.MessageHandler.Context	getContext()	Return the stream MessageHandler.Context for the message.
long	getCreationTime()	See Properties.getCreationTime().
@Nullable String	getGroupId()	See Properties.getGroupId().
long	getGroupSequence()	See Properties.getGroupSequence().
@Nullable String	getReplyToGroupId()	See Properties.getReplyToGroupId().
@Nullable String	getSubject()	See Properties.getSubject().
@Nullable String	getTo()	See Properties.getTo().
int	hashCode()
void	setCreationTime(long creationTime)	See MessageBuilder.PropertiesBuilder.creationTime(long).
void	setGroupId(String groupId)	See MessageBuilder.PropertiesBuilder.groupId(String).
void	setGroupSequence(long groupSequence)	See MessageBuilder.PropertiesBuilder.groupSequence(long).
void	setReplyToGroupId(String replyToGroupId)	See MessageBuilder.PropertiesBuilder.replyToGroupId(String).
void	setSubject(String subject)	See MessageBuilder.PropertiesBuilder.subject(String).
void	setTo(String address)	See MessageBuilder.PropertiesBuilder.to(String).

Methods inherited from class org.springframework.amqp.core.MessageProperties

getAmqpAcknowledgment, getAppId, getClusterId, getConsumerQueue, getConsumerTag, getContentEncoding, getContentLength, getContentType, getCorrelationId, getDelayLong, getDeliveryMode, getDeliveryTag, getExpiration, getHeader, getHeaders, getInferredArgumentType, getMessageCount, getMessageId, getPriority, getPublishSequenceNumber, getReceivedDelayLong, getReceivedDeliveryMode, getReceivedExchange, getReceivedRoutingKey, getReceivedUserId, getRedelivered, getReplyTo, getReplyToAddress, getRetryCount, getTargetBean, getTargetMethod, getTimestamp, getType, getUserId, getXDeathHeader, incrementRetryCount, isContentLengthSet, isDeliveryTagSet, isFinalRetryForMessageWithNoId, isLastInBatch, isProjectionUsed, isRedelivered, setAmqpAcknowledgment, setAppId, setClusterId, setConsumerQueue, setConsumerTag, setContentEncoding, setContentLength, setContentType, setCorrelationId, setDelayLong, setDeliveryMode, setDeliveryTag, setExpiration, setFinalRetryForMessageWithNoId, setHeader, setHeaders, setInferredArgumentType, setLastInBatch, setMessageCount, setMessageId, setPriority, setProjectionUsed, setPublishSequenceNumber, setReceivedDelayLong, setReceivedDeliveryMode, setReceivedExchange, setReceivedRoutingKey, setReceivedUserId, setRedelivered, setReplyTo, setReplyToAddress, setRetryCount, setTargetBean, setTargetMethod, setTimestamp, setType, setUserId, toString

Methods inherited from class java.lang.Object

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

Constructor Details

StreamMessageProperties

public StreamMessageProperties()

Create a new instance.

StreamMessageProperties

public StreamMessageProperties(@Nullable com.rabbitmq.stream.MessageHandler.Context context)

Create a new instance with the provided context.

Parameters:

context - the context.

Method Details

getContext

public @Nullable com.rabbitmq.stream.MessageHandler.Context getContext()

Return the stream MessageHandler.Context for the message.

Returns:

the context.

getTo

public @Nullable String getTo()

See Properties.getTo().

Returns:

the to address.

setTo

public void setTo(String address)

See MessageBuilder.PropertiesBuilder.to(String).

Parameters:

address - the address.

getSubject

public @Nullable String getSubject()

See Properties.getSubject().

Returns:

the subject.

setSubject

public void setSubject(String subject)

See MessageBuilder.PropertiesBuilder.subject(String).

Parameters:

subject - the subject.

getCreationTime

public long getCreationTime()

See Properties.getCreationTime().

Returns:

the creation time.

setCreationTime

public void setCreationTime(long creationTime)

See MessageBuilder.PropertiesBuilder.creationTime(long).

Parameters:

creationTime - the creation time.

getGroupId

public @Nullable String getGroupId()

See Properties.getGroupId().

Returns:

the group id.

setGroupId

public void setGroupId(String groupId)

See MessageBuilder.PropertiesBuilder.groupId(String).

Parameters:

groupId - the group id.

getGroupSequence

public long getGroupSequence()

See Properties.getGroupSequence().

Returns:

the group sequence.

setGroupSequence

public void setGroupSequence(long groupSequence)

See MessageBuilder.PropertiesBuilder.groupSequence(long).

Parameters:

groupSequence - the group sequence.

getReplyToGroupId

public @Nullable String getReplyToGroupId()

See Properties.getReplyToGroupId().

Returns:

the reply to group id.

setReplyToGroupId

public void setReplyToGroupId(String replyToGroupId)

See MessageBuilder.PropertiesBuilder.replyToGroupId(String).

Parameters:

replyToGroupId - the reply to group id.

hashCode

public int hashCode()

Overrides:

hashCode in class MessageProperties

equals

public boolean equals(Object obj)

Overrides:

equals in class MessageProperties