org.springframework.amqp.core

Class MessageProperties

java.lang.Object

org.springframework.amqp.core.MessageProperties

All Implemented Interfaces:

java.io.Serializable

public class MessageProperties
extends java.lang.Object
implements java.io.Serializable

Message Properties for an AMQP message.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	appId
private java.lang.String	clusterId
static java.lang.String	CONTENT_TYPE_BYTES
static java.lang.String	CONTENT_TYPE_JSON
static java.lang.String	CONTENT_TYPE_JSON_ALT
static java.lang.String	CONTENT_TYPE_SERIALIZED_OBJECT
static java.lang.String	CONTENT_TYPE_TEXT_PLAIN
static java.lang.String	CONTENT_TYPE_XML
private java.lang.String	contentEncoding
private long	contentLength
private boolean	contentLengthSet
private java.lang.String	contentType
private byte[]	correlationId
(package private) static java.lang.String	DEFAULT_CONTENT_TYPE
(package private) static MessageDeliveryMode	DEFAULT_DELIVERY_MODE
(package private) static java.lang.Integer	DEFAULT_PRIORITY
private MessageDeliveryMode	deliveryMode
private long	deliveryTag
private boolean	deliveryTagSet
private java.lang.String	expiration
private java.util.Map<java.lang.String,java.lang.Object>	headers
private java.lang.Integer	messageCount
private java.lang.String	messageId
private java.lang.Integer	priority
private java.lang.String	receivedExchange
private java.lang.String	receivedRoutingKey
private java.lang.Boolean	redelivered
private java.lang.String	replyTo
private static long	serialVersionUID
private java.util.Date	timestamp
private java.lang.String	type
private java.lang.String	userId

Constructor Summary

Constructors

Constructor and Description
MessageProperties()

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getAppId()
java.lang.String	getClusterId()
java.lang.String	getContentEncoding()
long	getContentLength()
java.lang.String	getContentType()
byte[]	getCorrelationId()
MessageDeliveryMode	getDeliveryMode()
long	getDeliveryTag()
java.lang.String	getExpiration()
java.util.Map<java.lang.String,java.lang.Object>	getHeaders()
java.lang.Integer	getMessageCount()
java.lang.String	getMessageId()
java.lang.Integer	getPriority()
java.lang.String	getReceivedExchange()
java.lang.String	getReceivedRoutingKey()
java.lang.Boolean	getRedelivered()
java.lang.String	getReplyTo()
Address	getReplyToAddress()
java.util.Date	getTimestamp()
java.lang.String	getType()
java.lang.String	getUserId()
int	hashCode()
protected boolean	isContentLengthSet()
protected boolean	isDeliveryTagSet()
java.lang.Boolean	isRedelivered()
void	setAppId(java.lang.String appId)
void	setClusterId(java.lang.String clusterId)
void	setContentEncoding(java.lang.String contentEncoding)
void	setContentLength(long contentLength)
void	setContentType(java.lang.String contentType)
void	setCorrelationId(byte[] correlationId)
void	setDeliveryMode(MessageDeliveryMode deliveryMode)
void	setDeliveryTag(long deliveryTag)
void	setExpiration(java.lang.String expiration)
void	setHeader(java.lang.String key, java.lang.Object value)
void	setMessageCount(java.lang.Integer messageCount)
void	setMessageId(java.lang.String messageId)
void	setPriority(java.lang.Integer priority)
void	setReceivedExchange(java.lang.String receivedExchange)
void	setReceivedRoutingKey(java.lang.String receivedRoutingKey)
void	setRedelivered(java.lang.Boolean redelivered)
void	setReplyTo(java.lang.String replyTo)
void	setReplyToAddress(Address replyTo)
void	setTimestamp(java.util.Date timestamp)
void	setType(java.lang.String type)
void	setUserId(java.lang.String userId)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

CONTENT_TYPE_BYTES

public static final java.lang.String CONTENT_TYPE_BYTES

See Also:

Constant Field Values

CONTENT_TYPE_TEXT_PLAIN

public static final java.lang.String CONTENT_TYPE_TEXT_PLAIN

See Also:

Constant Field Values

CONTENT_TYPE_SERIALIZED_OBJECT

public static final java.lang.String CONTENT_TYPE_SERIALIZED_OBJECT

See Also:

Constant Field Values

CONTENT_TYPE_JSON

public static final java.lang.String CONTENT_TYPE_JSON

See Also:

Constant Field Values

CONTENT_TYPE_JSON_ALT

public static final java.lang.String CONTENT_TYPE_JSON_ALT

See Also:

Constant Field Values

CONTENT_TYPE_XML

public static final java.lang.String CONTENT_TYPE_XML

See Also:

Constant Field Values

DEFAULT_CONTENT_TYPE

static final java.lang.String DEFAULT_CONTENT_TYPE

See Also:

Constant Field Values

DEFAULT_DELIVERY_MODE

static final MessageDeliveryMode DEFAULT_DELIVERY_MODE

DEFAULT_PRIORITY

static final java.lang.Integer DEFAULT_PRIORITY

headers

private final java.util.Map<java.lang.String,java.lang.Object> headers

timestamp

private volatile java.util.Date timestamp

messageId

private volatile java.lang.String messageId

userId

private volatile java.lang.String userId

appId

private volatile java.lang.String appId

clusterId

private volatile java.lang.String clusterId

type

private volatile java.lang.String type

correlationId

private volatile byte[] correlationId

replyTo

private volatile java.lang.String replyTo

contentType

private volatile java.lang.String contentType

contentEncoding

private volatile java.lang.String contentEncoding

contentLength

private volatile long contentLength

contentLengthSet

private volatile boolean contentLengthSet

deliveryMode

private volatile MessageDeliveryMode deliveryMode

expiration

private volatile java.lang.String expiration

priority

private volatile java.lang.Integer priority

redelivered

private volatile java.lang.Boolean redelivered

receivedExchange

private volatile java.lang.String receivedExchange

receivedRoutingKey

private volatile java.lang.String receivedRoutingKey

deliveryTag

private volatile long deliveryTag

deliveryTagSet

private volatile boolean deliveryTagSet

messageCount

private volatile java.lang.Integer messageCount

Constructor Detail

MessageProperties

public MessageProperties()

Method Detail

setHeader

public void setHeader(java.lang.String key,
                      java.lang.Object value)

getHeaders

public java.util.Map<java.lang.String,java.lang.Object> getHeaders()

setTimestamp

public void setTimestamp(java.util.Date timestamp)

getTimestamp

public java.util.Date getTimestamp()

setMessageId

public void setMessageId(java.lang.String messageId)

getMessageId

public java.lang.String getMessageId()

setUserId

public void setUserId(java.lang.String userId)

getUserId

public java.lang.String getUserId()

setAppId

public void setAppId(java.lang.String appId)

getAppId

public java.lang.String getAppId()

setClusterId

public void setClusterId(java.lang.String clusterId)

getClusterId

public java.lang.String getClusterId()

setType

public void setType(java.lang.String type)

getType

public java.lang.String getType()

setCorrelationId

public void setCorrelationId(byte[] correlationId)

getCorrelationId

public byte[] getCorrelationId()

setReplyTo

public void setReplyTo(java.lang.String replyTo)

getReplyTo

public java.lang.String getReplyTo()

setReplyToAddress

public void setReplyToAddress(Address replyTo)

getReplyToAddress

public Address getReplyToAddress()

setContentType

public void setContentType(java.lang.String contentType)

getContentType

public java.lang.String getContentType()

setContentEncoding

public void setContentEncoding(java.lang.String contentEncoding)

getContentEncoding

public java.lang.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()

setExpiration

public void setExpiration(java.lang.String expiration)

getExpiration

public java.lang.String getExpiration()

setPriority

public void setPriority(java.lang.Integer priority)

getPriority

public java.lang.Integer getPriority()

setReceivedExchange

public void setReceivedExchange(java.lang.String receivedExchange)

getReceivedExchange

public java.lang.String getReceivedExchange()

setReceivedRoutingKey

public void setReceivedRoutingKey(java.lang.String receivedRoutingKey)

getReceivedRoutingKey

public java.lang.String getReceivedRoutingKey()

setRedelivered

public void setRedelivered(java.lang.Boolean redelivered)

isRedelivered

public java.lang.Boolean isRedelivered()

getRedelivered

public java.lang.Boolean getRedelivered()

setDeliveryTag

public void setDeliveryTag(long deliveryTag)

getDeliveryTag

public long getDeliveryTag()

isDeliveryTagSet

protected final boolean isDeliveryTagSet()

setMessageCount

public void setMessageCount(java.lang.Integer messageCount)

getMessageCount

public java.lang.Integer getMessageCount()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object