Class StreamMessageProperties
java.lang.Object
org.springframework.amqp.core.MessageProperties
org.springframework.rabbit.stream.support.StreamMessageProperties
- All Implemented Interfaces:
Serializable
public class StreamMessageProperties
extends org.springframework.amqp.core.MessageProperties
MessageProperties extension for stream messages.- Since:
- 2.4
- See Also:
-
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, SPRING_AUTO_DECOMPRESS, SPRING_BATCH_FORMAT, X_DELAY -
Constructor Summary
ConstructorsConstructorDescriptionCreate a new instance.StreamMessageProperties(com.rabbitmq.stream.MessageHandler.Context context) Create a new instance with the provided context. -
Method Summary
Modifier and TypeMethodDescriptionbooleancom.rabbitmq.stream.MessageHandler.ContextReturn the streamMessageHandler.Contextfor the message.longSeeProperties.getCreationTime().SeeProperties.getGroupId().longSeeProperties.getGroupSequence().SeeProperties.getReplyToGroupId().SeeProperties.getSubject().getTo()SeeProperties.getTo().inthashCode()voidsetCreationTime(long creationTime) SeeMessageBuilder.PropertiesBuilder.creationTime(long).voidsetGroupId(String groupId) SeeMessageBuilder.PropertiesBuilder.groupId(String).voidsetGroupSequence(long groupSequence) SeeMessageBuilder.PropertiesBuilder.groupSequence(long).voidsetReplyToGroupId(String replyToGroupId) SeeMessageBuilder.PropertiesBuilder.replyToGroupId(String).voidsetSubject(String subject) SeeMessageBuilder.PropertiesBuilder.subject(String).voidSeeMessageBuilder.PropertiesBuilder.to(String).Methods inherited from class org.springframework.amqp.core.MessageProperties
getAppId, getClusterId, getConsumerQueue, getConsumerTag, getContentEncoding, getContentLength, getContentType, getCorrelationId, getDelay, getDeliveryMode, getDeliveryTag, getExpiration, getHeader, getHeaders, getInferredArgumentType, getMessageCount, getMessageId, getPriority, getPublishSequenceNumber, getReceivedDelay, getReceivedDeliveryMode, getReceivedExchange, getReceivedRoutingKey, getReceivedUserId, getRedelivered, getReplyTo, getReplyToAddress, getTargetBean, getTargetMethod, getTimestamp, getType, getUserId, getXDeathHeader, isContentLengthSet, isDeliveryTagSet, isFinalRetryForMessageWithNoId, isLastInBatch, isProjectionUsed, isRedelivered, setAppId, setClusterId, setConsumerQueue, setConsumerTag, setContentEncoding, setContentLength, setContentType, setCorrelationId, setDelay, setDeliveryMode, setDeliveryTag, setExpiration, setFinalRetryForMessageWithNoId, setHeader, setInferredArgumentType, setLastInBatch, setMessageCount, setMessageId, setPriority, setProjectionUsed, setPublishSequenceNumber, setReceivedDelay, setReceivedDeliveryMode, setReceivedExchange, setReceivedRoutingKey, setReceivedUserId, setRedelivered, setReplyTo, setReplyToAddress, setTargetBean, setTargetMethod, setTimestamp, setType, setUserId, toString
-
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
@Nullable public com.rabbitmq.stream.MessageHandler.Context getContext()Return the streamMessageHandler.Contextfor the message.- Returns:
- the context.
-
getTo
SeeProperties.getTo().- Returns:
- the to address.
-
setTo
SeeMessageBuilder.PropertiesBuilder.to(String).- Parameters:
address- the address.
-
getSubject
SeeProperties.getSubject().- Returns:
- the subject.
-
setSubject
SeeMessageBuilder.PropertiesBuilder.subject(String).- Parameters:
subject- the subject.
-
getCreationTime
public long getCreationTime()SeeProperties.getCreationTime().- Returns:
- the creation time.
-
setCreationTime
public void setCreationTime(long creationTime) SeeMessageBuilder.PropertiesBuilder.creationTime(long).- Parameters:
creationTime- the creation time.
-
getGroupId
SeeProperties.getGroupId().- Returns:
- the group id.
-
setGroupId
SeeMessageBuilder.PropertiesBuilder.groupId(String).- Parameters:
groupId- the group id.
-
getGroupSequence
public long getGroupSequence()SeeProperties.getGroupSequence().- Returns:
- the group sequence.
-
setGroupSequence
public void setGroupSequence(long groupSequence) SeeMessageBuilder.PropertiesBuilder.groupSequence(long).- Parameters:
groupSequence- the group sequence.
-
getReplyToGroupId
SeeProperties.getReplyToGroupId().- Returns:
- the reply to group id.
-
setReplyToGroupId
SeeMessageBuilder.PropertiesBuilder.replyToGroupId(String).- Parameters:
replyToGroupId- the reply to group id.
-
hashCode
public int hashCode()- Overrides:
hashCodein classorg.springframework.amqp.core.MessageProperties
-
equals
- Overrides:
equalsin classorg.springframework.amqp.core.MessageProperties
-