Package org.springframework.amqp.core
Class MessageProperties
- java.lang.Object
-
- org.springframework.amqp.core.MessageProperties
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
StreamMessageProperties
public class MessageProperties extends Object implements Serializable
Message Properties for an AMQP message.- Author:
- Mark Fisher, Mark Pollack, Gary Russell, Dmitry Chernyshov, Artem Bilan, Csaba Soti
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static StringBATCH_FORMAT_LENGTH_HEADER4static StringCONTENT_TYPE_BYTESstatic StringCONTENT_TYPE_JSONstatic StringCONTENT_TYPE_JSON_ALTstatic StringCONTENT_TYPE_SERIALIZED_OBJECTstatic StringCONTENT_TYPE_TEXT_PLAINstatic StringCONTENT_TYPE_XMLstatic StringDEFAULT_CONTENT_TYPEstatic MessageDeliveryModeDEFAULT_DELIVERY_MODEstatic IntegerDEFAULT_PRIORITYstatic StringSPRING_AUTO_DECOMPRESSstatic StringSPRING_BATCH_FORMATstatic StringX_DELAY
-
Constructor Summary
Constructors Constructor Description MessageProperties()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)StringgetAppId()StringgetClusterId()StringgetConsumerQueue()StringgetConsumerTag()StringgetContentEncoding()longgetContentLength()StringgetContentType()StringgetCorrelationId()Get the correlation id.IntegergetDelay()The x-delay header (outbound).MessageDeliveryModegetDeliveryMode()longgetDeliveryTag()StringgetExpiration()<T> TgetHeader(String headerName)Typed getter for a header.Map<String,Object>getHeaders()TypegetInferredArgumentType()The inferred target argument type when using a method-level@RabbitListener.IntegergetMessageCount()Return the server's most recent estimate of the number of messages remaining on the queue.StringgetMessageId()IntegergetPriority()longgetPublishSequenceNumber()Return the publish sequence number if publisher confirms are enabled; set by the template.IntegergetReceivedDelay()When a delayed message exchange is used the x-delay header on a received message contains the delay.MessageDeliveryModegetReceivedDeliveryMode()StringgetReceivedExchange()StringgetReceivedRoutingKey()StringgetReceivedUserId()Return the user id from an incoming message.BooleangetRedelivered()StringgetReplyTo()AddressgetReplyToAddress()ObjectgetTargetBean()The target bean when using@RabbitListener.MethodgetTargetMethod()The target method when using a@RabbitListener.DategetTimestamp()StringgetType()StringgetUserId()List<Map<String,?>>getXDeathHeader()Return the x-death header.inthashCode()protected booleanisContentLengthSet()protected booleanisDeliveryTagSet()booleanisFinalRetryForMessageWithNoId()booleanisLastInBatch()When true; the message having these properties is the last message from a batch.booleanisProjectionUsed()Get an internal flag used to communicate that conversion used projection; always false at the application level.BooleanisRedelivered()voidsetAppId(String appId)voidsetClusterId(String clusterId)voidsetConsumerQueue(String consumerQueue)voidsetConsumerTag(String consumerTag)voidsetContentEncoding(String contentEncoding)voidsetContentLength(long contentLength)voidsetContentType(String contentType)voidsetCorrelationId(String correlationId)Set the correlation id.voidsetDelay(Integer delay)Set the x-delay header.voidsetDeliveryMode(MessageDeliveryMode deliveryMode)voidsetDeliveryTag(long deliveryTag)voidsetExpiration(String expiration)voidsetFinalRetryForMessageWithNoId(boolean finalRetryForMessageWithNoId)voidsetHeader(String key, Object value)voidsetInferredArgumentType(Type inferredArgumentType)Set the inferred target argument type when using a method-level@RabbitListener.voidsetLastInBatch(boolean lastInBatch)Set to true to indicate these properties are for the last message in a batch.voidsetMessageCount(Integer messageCount)Set the message count.voidsetMessageId(String messageId)voidsetPriority(Integer priority)voidsetProjectionUsed(boolean projectionUsed)Set an internal flag used to communicate that conversion used projection; always false at the application level.voidsetPublishSequenceNumber(long publishSequenceNumber)Set the publish sequence number, if publisher confirms are enabled; set by the template.voidsetReceivedDelay(Integer receivedDelay)When a delayed message exchange is used the x-delay header on a received message contains the delay.voidsetReceivedDeliveryMode(MessageDeliveryMode receivedDeliveryMode)voidsetReceivedExchange(String receivedExchange)voidsetReceivedRoutingKey(String receivedRoutingKey)voidsetReceivedUserId(String receivedUserId)voidsetRedelivered(Boolean redelivered)voidsetReplyTo(String replyTo)voidsetReplyToAddress(Address replyTo)voidsetTargetBean(Object targetBean)Set the target bean when using@RabbitListener.voidsetTargetMethod(Method targetMethod)Set the target method when using a@RabbitListener.voidsetTimestamp(Date timestamp)voidsetType(String type)voidsetUserId(String userId)StringtoString()
-
-
-
Field Detail
-
CONTENT_TYPE_BYTES
public static final String CONTENT_TYPE_BYTES
- See Also:
- Constant Field Values
-
CONTENT_TYPE_TEXT_PLAIN
public static final String CONTENT_TYPE_TEXT_PLAIN
- See Also:
- Constant Field Values
-
CONTENT_TYPE_SERIALIZED_OBJECT
public static final String CONTENT_TYPE_SERIALIZED_OBJECT
- See Also:
- Constant Field Values
-
CONTENT_TYPE_JSON
public static final String CONTENT_TYPE_JSON
- See Also:
- Constant Field Values
-
CONTENT_TYPE_JSON_ALT
public static final String CONTENT_TYPE_JSON_ALT
- See Also:
- Constant Field Values
-
CONTENT_TYPE_XML
public static final String CONTENT_TYPE_XML
- See Also:
- Constant Field Values
-
SPRING_BATCH_FORMAT
public static final String SPRING_BATCH_FORMAT
- See Also:
- Constant Field Values
-
BATCH_FORMAT_LENGTH_HEADER4
public static final String BATCH_FORMAT_LENGTH_HEADER4
- See Also:
- Constant Field Values
-
SPRING_AUTO_DECOMPRESS
public static final String SPRING_AUTO_DECOMPRESS
- See Also:
- Constant Field Values
-
X_DELAY
public static final String X_DELAY
- See Also:
- Constant Field Values
-
DEFAULT_CONTENT_TYPE
public static final String DEFAULT_CONTENT_TYPE
- See Also:
- Constant Field Values
-
DEFAULT_DELIVERY_MODE
public static final MessageDeliveryMode DEFAULT_DELIVERY_MODE
-
DEFAULT_PRIORITY
public static final Integer DEFAULT_PRIORITY
-
-
Method Detail
-
getHeader
public <T> T getHeader(String headerName)
Typed getter for a header.- Type Parameters:
T- the type.- Parameters:
headerName- the header name.- Returns:
- the header value
- Since:
- 2.2
-
setTimestamp
public void setTimestamp(Date timestamp)
-
getTimestamp
public Date getTimestamp()
-
setMessageId
public void setMessageId(String messageId)
-
getMessageId
public String getMessageId()
-
setUserId
public void setUserId(String userId)
-
getUserId
public String getUserId()
-
getReceivedUserId
public String getReceivedUserId()
Return the user id from an incoming message.- Returns:
- the user id.
- Since:
- 1.6
-
setReceivedUserId
public void setReceivedUserId(String receivedUserId)
-
setAppId
public void setAppId(String appId)
-
getAppId
public String getAppId()
-
setClusterId
public void setClusterId(String clusterId)
-
getClusterId
public String getClusterId()
-
setType
public void setType(String type)
-
getType
public String getType()
-
setCorrelationId
public void setCorrelationId(String correlationId)
Set the correlation id.- Parameters:
correlationId- the id.
-
getCorrelationId
public String getCorrelationId()
Get the correlation id.- Returns:
- the id.
-
setReplyTo
public void setReplyTo(String replyTo)
-
getReplyTo
public String getReplyTo()
-
setReplyToAddress
public void setReplyToAddress(Address replyTo)
-
getReplyToAddress
public Address getReplyToAddress()
-
setContentType
public void setContentType(String contentType)
-
getContentType
public String getContentType()
-
setContentEncoding
public void setContentEncoding(String contentEncoding)
-
getContentEncoding
public String getContentEncoding()
-
setContentLength
public void setContentLength(long contentLength)
-
getContentLength
public long getContentLength()
-
isContentLengthSet
protected final boolean isContentLengthSet()
-
setDeliveryMode
public void setDeliveryMode(MessageDeliveryMode deliveryMode)
-
getDeliveryMode
public MessageDeliveryMode getDeliveryMode()
-
getReceivedDeliveryMode
public MessageDeliveryMode getReceivedDeliveryMode()
-
setReceivedDeliveryMode
public void setReceivedDeliveryMode(MessageDeliveryMode receivedDeliveryMode)
-
setExpiration
public void setExpiration(String expiration)
-
getExpiration
public String getExpiration()
-
setPriority
public void setPriority(Integer priority)
-
getPriority
public Integer getPriority()
-
setReceivedExchange
public void setReceivedExchange(String receivedExchange)
-
getReceivedExchange
public String getReceivedExchange()
-
setReceivedRoutingKey
public void setReceivedRoutingKey(String receivedRoutingKey)
-
getReceivedRoutingKey
public String getReceivedRoutingKey()
-
getReceivedDelay
public Integer getReceivedDelay()
When a delayed message exchange is used the x-delay header on a received message contains the delay.- Returns:
- the received delay.
- Since:
- 1.6
- See Also:
getDelay()
-
setReceivedDelay
public void setReceivedDelay(Integer receivedDelay)
When a delayed message exchange is used the x-delay header on a received message contains the delay.- Parameters:
receivedDelay- the received delay.- Since:
- 1.6
-
setRedelivered
public void setRedelivered(Boolean redelivered)
-
isRedelivered
public Boolean isRedelivered()
-
getRedelivered
public Boolean getRedelivered()
-
setDeliveryTag
public void setDeliveryTag(long deliveryTag)
-
getDeliveryTag
public long getDeliveryTag()
-
isDeliveryTagSet
protected final boolean isDeliveryTagSet()
-
setMessageCount
public void setMessageCount(Integer messageCount)
Set the message count.- Parameters:
messageCount- the count- See Also:
getMessageCount()
-
getMessageCount
public Integer getMessageCount()
Return the server's most recent estimate of the number of messages remaining on the queue. Only applies to messages retrieved viabasicGet.- Returns:
- the count.
-
getConsumerTag
public String getConsumerTag()
-
setConsumerTag
public void setConsumerTag(String consumerTag)
-
getConsumerQueue
public String getConsumerQueue()
-
setConsumerQueue
public void setConsumerQueue(String consumerQueue)
-
getDelay
public Integer getDelay()
The x-delay header (outbound).- Returns:
- the delay.
- Since:
- 1.6
- See Also:
getReceivedDelay()
-
setDelay
public void setDelay(Integer delay)
Set the x-delay header.- Parameters:
delay- the delay.- Since:
- 1.6
-
isFinalRetryForMessageWithNoId
public boolean isFinalRetryForMessageWithNoId()
-
setFinalRetryForMessageWithNoId
public void setFinalRetryForMessageWithNoId(boolean finalRetryForMessageWithNoId)
-
getPublishSequenceNumber
public long getPublishSequenceNumber()
Return the publish sequence number if publisher confirms are enabled; set by the template.- Returns:
- the sequence number.
- Since:
- 2.1
-
setPublishSequenceNumber
public void setPublishSequenceNumber(long publishSequenceNumber)
Set the publish sequence number, if publisher confirms are enabled; set by the template.- Parameters:
publishSequenceNumber- the sequence number.- Since:
- 2.1
-
getInferredArgumentType
public Type getInferredArgumentType()
The inferred target argument type when using a method-level@RabbitListener.- Returns:
- the type.
- Since:
- 1.6
-
setInferredArgumentType
public void setInferredArgumentType(Type inferredArgumentType)
Set the inferred target argument type when using a method-level@RabbitListener.- Parameters:
inferredArgumentType- the type.- Since:
- 1.6
-
getTargetMethod
public Method getTargetMethod()
The target method when using a@RabbitListener.- Returns:
- the method.
- Since:
- 1.6
-
setTargetMethod
public void setTargetMethod(Method targetMethod)
Set the target method when using a@RabbitListener.- Parameters:
targetMethod- the target method.- Since:
- 1.6
-
getTargetBean
public Object getTargetBean()
The target bean when using@RabbitListener.- Returns:
- the bean.
- Since:
- 1.6
-
setTargetBean
public void setTargetBean(Object targetBean)
Set the target bean when using@RabbitListener.- Parameters:
targetBean- the bean.- Since:
- 1.6
-
isLastInBatch
public boolean isLastInBatch()
When true; the message having these properties is the last message from a batch.- Returns:
- true for the last message.
- Since:
- 2.2
-
setLastInBatch
public void setLastInBatch(boolean lastInBatch)
Set to true to indicate these properties are for the last message in a batch.- Parameters:
lastInBatch- true for the last.- Since:
- 2.2
-
isProjectionUsed
public boolean isProjectionUsed()
Get an internal flag used to communicate that conversion used projection; always false at the application level.- Returns:
- true if projection was used.
- Since:
- 2.2.20
-
setProjectionUsed
public void setProjectionUsed(boolean projectionUsed)
Set an internal flag used to communicate that conversion used projection; always false at the application level.- Parameters:
projectionUsed- true for projection.- Since:
- 2.2.20
-
getXDeathHeader
public List<Map<String,?>> getXDeathHeader()
Return the x-death header.- Returns:
- the header.
-
-