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

    Constructors
    Constructor
    Description
    Create a new instance.
    StreamMessageProperties(com.rabbitmq.stream.MessageHandler.Context context)
    Create a new instance with the provided context.
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
     
    com.rabbitmq.stream.MessageHandler.Context
    Return the stream MessageHandler.Context for the message.
    long
    See Properties.getCreationTime().
    See Properties.getGroupId().
    long
    See Properties.getGroupSequence().
    See Properties.getReplyToGroupId().
    See Properties.getSubject().
    See Properties.getTo().
    int
     
    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

    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

    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

      @Nullable public com.rabbitmq.stream.MessageHandler.Context getContext()
      Return the stream MessageHandler.Context for the message.
      Returns:
      the context.
    • getTo

      public 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 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 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 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 org.springframework.amqp.core.MessageProperties
    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class org.springframework.amqp.core.MessageProperties