Class StreamMessageProperties

  • All Implemented Interfaces:
    java.io.Serializable

    public class StreamMessageProperties
    extends org.springframework.amqp.core.MessageProperties
    MessageProperties extension for stream messages.
    Since:
    2.4
    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, SPRING_AUTO_DECOMPRESS, SPRING_BATCH_FORMAT, X_DELAY
    • Constructor Summary

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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean equals​(java.lang.Object obj)  
      com.rabbitmq.stream.MessageHandler.Context getContext()
      Return the stream MessageHandler.Context for the message.
      long getCreationTime()
      See Properties.getCreationTime().
      java.lang.String getGroupId()
      See Properties.getGroupId().
      long getGroupSequence()
      See Properties.getGroupSequence().
      java.lang.String getReplyToGroupId()
      See Properties.getReplyToGroupId().
      java.lang.String getSubject()
      See Properties.getSubject().
      java.lang.String getTo()
      See Properties.getTo().
      int hashCode()  
      void setCreationTime​(long creationTime)
      See MessageBuilder.PropertiesBuilder.creationTime(long).
      void setGroupId​(java.lang.String groupId)
      See MessageBuilder.PropertiesBuilder.groupId(String).
      void setGroupSequence​(long groupSequence)
      See MessageBuilder.PropertiesBuilder.groupSequence(long).
      void setReplyToGroupId​(java.lang.String replyToGroupId)
      See MessageBuilder.PropertiesBuilder.replyToGroupId(String).
      void setSubject​(java.lang.String subject)
      See MessageBuilder.PropertiesBuilder.subject(String).
      void setTo​(java.lang.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 Detail

      • 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 Detail

      • getContext

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

        public java.lang.String getTo()
        See Properties.getTo().
        Returns:
        the to address.
      • setTo

        public void setTo​(java.lang.String address)
        See MessageBuilder.PropertiesBuilder.to(String).
        Parameters:
        address - the address.
      • getSubject

        public java.lang.String getSubject()
        See Properties.getSubject().
        Returns:
        the subject.
      • setSubject

        public void setSubject​(java.lang.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 java.lang.String getGroupId()
        See Properties.getGroupId().
        Returns:
        the group id.
      • setGroupId

        public void setGroupId​(java.lang.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 java.lang.String getReplyToGroupId()
        See Properties.getReplyToGroupId().
        Returns:
        the reply to group id.
      • setReplyToGroupId

        public void setReplyToGroupId​(java.lang.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​(java.lang.Object obj)
        Overrides:
        equals in class org.springframework.amqp.core.MessageProperties