org.springframework.amqp.rabbit.core
Class RabbitMessageProperties
java.lang.Object
org.springframework.amqp.rabbit.core.RabbitMessageProperties
- All Implemented Interfaces:
- MessageProperties
public class RabbitMessageProperties
- extends Object
- implements MessageProperties
Rabbit implementation of MessageProperties that stores much of the message property
information in Rabbit's BasicProperites class. Empty headers will be created on
demand if they are null in the underlying BasicProperties instance.
- Author:
- Mark Pollack, Mark Fisher
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RabbitMessageProperties
public RabbitMessageProperties()
RabbitMessageProperties
public RabbitMessageProperties(com.rabbitmq.client.AMQP.BasicProperties basicProperties,
String receivedExchange,
String receivedRoutingKey,
Boolean redelivered,
long deliveryTag,
int messageCount)
- Parameters:
basicProperties - receivedExchange - receivedRoutingKey - redelivered - deliveryTag - messageCount -
getBasicProperties
public com.rabbitmq.client.AMQP.BasicProperties getBasicProperties()
- Return Rabbit BasicProperties.
- Returns:
- the Rabbit BasicProperties
getHeaders
public Map<String,Object> getHeaders()
- Specified by:
getHeaders in interface MessageProperties
setHeader
public void setHeader(String key,
Object value)
- Specified by:
setHeader in interface MessageProperties
getTimestamp
public Date getTimestamp()
- Specified by:
getTimestamp in interface MessageProperties
setAppId
public void setAppId(String appId)
- Specified by:
setAppId in interface MessageProperties
getAppId
public String getAppId()
- Specified by:
getAppId in interface MessageProperties
setUserId
public void setUserId(String userId)
- Specified by:
setUserId in interface MessageProperties
getUserId
public String getUserId()
- Specified by:
getUserId in interface MessageProperties
setType
public void setType(String type)
- Specified by:
setType in interface MessageProperties
getType
public String getType()
- Specified by:
getType in interface MessageProperties
setMessageId
public void setMessageId(String id)
- Specified by:
setMessageId in interface MessageProperties
getMessageId
public String getMessageId()
- Specified by:
getMessageId in interface MessageProperties
setClusterId
public void setClusterId(String id)
- Specified by:
setClusterId in interface MessageProperties
getClusterId
public String getClusterId()
- Specified by:
getClusterId in interface MessageProperties
setCorrelationId
public void setCorrelationId(byte[] correlationId)
- Specified by:
setCorrelationId in interface MessageProperties
getCorrelationId
public byte[] getCorrelationId()
- Specified by:
getCorrelationId in interface MessageProperties
setReplyTo
public void setReplyTo(Address replyTo)
- Specified by:
setReplyTo in interface MessageProperties
getReplyTo
public Address getReplyTo()
- Specified by:
getReplyTo in interface MessageProperties
setContentType
public void setContentType(String contentType)
- Specified by:
setContentType in interface MessageProperties
getContentType
public String getContentType()
- Specified by:
getContentType in interface MessageProperties
setContentEncoding
public void setContentEncoding(String contentEncoding)
- Specified by:
setContentEncoding in interface MessageProperties
getContentEncoding
public String getContentEncoding()
- Specified by:
getContentEncoding in interface MessageProperties
setContentLength
public void setContentLength(long contentLength)
- Specified by:
setContentLength in interface MessageProperties
getContentLength
public long getContentLength()
- Specified by:
getContentLength in interface MessageProperties
setDefaultCharset
public void setDefaultCharset(String charSet)
- Specified by:
setDefaultCharset in interface MessageProperties
setDeliveryMode
public void setDeliveryMode(MessageDeliveryMode deliveryMode)
- Specified by:
setDeliveryMode in interface MessageProperties
getDeliveryMode
public MessageDeliveryMode getDeliveryMode()
- Specified by:
getDeliveryMode in interface MessageProperties
setExpiration
public void setExpiration(String expiration)
- Specified by:
setExpiration in interface MessageProperties
getExpiration
public String getExpiration()
- Specified by:
getExpiration in interface MessageProperties
setPriority
public void setPriority(Integer priority)
- Specified by:
setPriority in interface MessageProperties
getPriority
public Integer getPriority()
- Specified by:
getPriority in interface MessageProperties
getReceivedExchange
public String getReceivedExchange()
- Specified by:
getReceivedExchange in interface MessageProperties
getReceivedRoutingKey
public String getReceivedRoutingKey()
- Specified by:
getReceivedRoutingKey in interface MessageProperties
isRedelivered
public Boolean isRedelivered()
- Specified by:
isRedelivered in interface MessageProperties
getDeliveryTag
public long getDeliveryTag()
- Specified by:
getDeliveryTag in interface MessageProperties
getMessageCount
public Integer getMessageCount()
- Specified by:
getMessageCount in interface MessageProperties
Copyright © 2010. All Rights Reserved.