Spring AMQP

org.springframework.amqp.rabbit.core
Class RabbitMessageProperties

java.lang.Object
  extended by 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

Field Summary
 
Fields inherited from interface org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_BYTES, CONTENT_TYPE_JSON, CONTENT_TYPE_SERIALIZED_OBJECT, CONTENT_TYPE_TEXT_PLAIN
 
Constructor Summary
RabbitMessageProperties()
           
RabbitMessageProperties(com.rabbitmq.client.AMQP.BasicProperties basicProperties, String receivedExchange, String receivedRoutingKey, Boolean redelivered, long deliveryTag, int messageCount)
           
 
Method Summary
 String getAppId()
           
 com.rabbitmq.client.AMQP.BasicProperties getBasicProperties()
          Return Rabbit BasicProperties.
 String getClusterId()
           
 String getContentEncoding()
           
 long getContentLength()
           
 String getContentType()
           
 byte[] getCorrelationId()
           
 MessageDeliveryMode getDeliveryMode()
           
 long getDeliveryTag()
           
 String getExpiration()
           
 Map<String,Object> getHeaders()
           
 Integer getMessageCount()
           
 String getMessageId()
           
 Integer getPriority()
           
 String getReceivedExchange()
           
 String getReceivedRoutingKey()
           
 Address getReplyTo()
           
 Date getTimestamp()
           
 String getType()
           
 String getUserId()
           
 Boolean isRedelivered()
           
 void setAppId(String appId)
           
 void setClusterId(String id)
           
 void setContentEncoding(String contentEncoding)
           
 void setContentLength(long contentLength)
           
 void setContentType(String contentType)
           
 void setCorrelationId(byte[] correlationId)
           
 void setDefaultCharset(String charSet)
           
 void setDeliveryMode(MessageDeliveryMode deliveryMode)
           
 void setExpiration(String expiration)
           
 void setHeader(String key, Object value)
           
 void setMessageId(String id)
           
 void setPriority(Integer priority)
           
 void setReplyTo(Address replyTo)
           
 void setType(String type)
           
 void setUserId(String userId)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

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

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

Spring AMQP

Copyright © 2010. All Rights Reserved.