Package org.springframework.amqp.core

Class MessageBuilderSupport<T>

java.lang.Object

org.springframework.amqp.core.MessageBuilderSupport<T>

Type Parameters:

T - The message builder type.

Direct Known Subclasses:

MessageBuilder, MessagePropertiesBuilder

public abstract class MessageBuilderSupport<T>
extends Object

Support class for building Message and MessageProperties fluent API.

Since:

1.3

Author:

Gary Russell

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MessageBuilderSupport()
protected	MessageBuilderSupport(MessageProperties properties)

Method Summary

Modifier and Type	Method	Description
abstract T	build()
protected MessageProperties	buildProperties()
MessageBuilderSupport<T>	copyHeaders(Map<String,Object> headers)
MessageBuilderSupport<T>	copyHeadersIfAbsent(Map<String,Object> headers)
MessageBuilderSupport<T>	copyProperties(MessageProperties properties)
MessageBuilderSupport<T>	removeHeader(String key)
MessageBuilderSupport<T>	removeHeaders()
MessageBuilderSupport<T>	setAppId(String appId)
MessageBuilderSupport<T>	setAppIdIfAbsent(String appId)
MessageBuilderSupport<T>	setClusterId(String clusterId)
MessageBuilderSupport<T>	setClusterIdIfAbsent(String clusterId)
MessageBuilderSupport<T>	setContentEncoding(String contentEncoding)
MessageBuilderSupport<T>	setContentEncodingIfAbsent(String contentEncoding)
MessageBuilderSupport<T>	setContentLength(long contentLength)
MessageBuilderSupport<T>	setContentLengthIfAbsent(long contentLength)
MessageBuilderSupport<T>	setContentType(String contentType)
MessageBuilderSupport<T>	setContentTypeIfAbsentOrDefault(String contentType)
MessageBuilderSupport<T>	setCorrelationId(String correlationId)
MessageBuilderSupport<T>	setCorrelationIdIfAbsent(String correlationId)
MessageBuilderSupport<T>	setDeliveryMode(MessageDeliveryMode deliveryMode)
MessageBuilderSupport<T>	setDeliveryModeIfAbsentOrDefault(MessageDeliveryMode deliveryMode)
MessageBuilderSupport<T>	setDeliveryTag(Long deliveryTag)
MessageBuilderSupport<T>	setDeliveryTagIfAbsent(Long deliveryTag)
MessageBuilderSupport<T>	setExpiration(String expiration)
MessageBuilderSupport<T>	setExpirationIfAbsent(String expiration)
MessageBuilderSupport<T>	setHeader(String key, Object value)
MessageBuilderSupport<T>	setHeaderIfAbsent(String key, Object value)
MessageBuilderSupport<T>	setMessageCount(Integer messageCount)
MessageBuilderSupport<T>	setMessageCountIfAbsent(Integer messageCount)
MessageBuilderSupport<T>	setMessageId(String messageId)
MessageBuilderSupport<T>	setMessageIdIfAbsent(String messageId)
MessageBuilderSupport<T>	setPriority(Integer priority)
MessageBuilderSupport<T>	setPriorityIfAbsentOrDefault(Integer priority)
protected void	setProperties(MessageProperties properties)
MessageBuilderSupport<T>	setReceivedExchange(String receivedExchange)
MessageBuilderSupport<T>	setReceivedExchangeIfAbsent(String receivedExchange)
MessageBuilderSupport<T>	setReceivedRoutingKey(String receivedRoutingKey)
MessageBuilderSupport<T>	setReceivedRoutingKeyIfAbsent(String receivedRoutingKey)
MessageBuilderSupport<T>	setRedelivered(Boolean redelivered)
MessageBuilderSupport<T>	setRedeliveredIfAbsent(Boolean redelivered)
MessageBuilderSupport<T>	setReplyTo(String replyTo)
MessageBuilderSupport<T>	setReplyToAddress(Address replyTo)
MessageBuilderSupport<T>	setReplyToAddressIfAbsent(Address replyTo)
MessageBuilderSupport<T>	setReplyToIfAbsent(String replyTo)
MessageBuilderSupport<T>	setTimestamp(Date timestamp)
MessageBuilderSupport<T>	setTimestampIfAbsent(Date timestamp)
MessageBuilderSupport<T>	setType(String type)
MessageBuilderSupport<T>	setTypeIfAbsent(String type)
MessageBuilderSupport<T>	setUserId(String userId)
MessageBuilderSupport<T>	setUserIdIfAbsent(String userId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageBuilderSupport

protected MessageBuilderSupport()

MessageBuilderSupport

protected MessageBuilderSupport(MessageProperties properties)

Method Details

setProperties

protected void setProperties(MessageProperties properties)

setHeader

public MessageBuilderSupport<T> setHeader(String key,
 Object value)

setTimestamp

public MessageBuilderSupport<T> setTimestamp(Date timestamp)

setMessageId

public MessageBuilderSupport<T> setMessageId(String messageId)

setUserId

public MessageBuilderSupport<T> setUserId(String userId)

setAppId

public MessageBuilderSupport<T> setAppId(String appId)

setClusterId

public MessageBuilderSupport<T> setClusterId(String clusterId)

setType

public MessageBuilderSupport<T> setType(String type)

setCorrelationId

public MessageBuilderSupport<T> setCorrelationId(String correlationId)

setReplyTo

public MessageBuilderSupport<T> setReplyTo(String replyTo)

setReplyToAddress

public MessageBuilderSupport<T> setReplyToAddress(Address replyTo)

setContentType

public MessageBuilderSupport<T> setContentType(String contentType)

setContentEncoding

public MessageBuilderSupport<T> setContentEncoding(String contentEncoding)

setContentLength

public MessageBuilderSupport<T> setContentLength(long contentLength)

setDeliveryMode

public MessageBuilderSupport<T> setDeliveryMode(MessageDeliveryMode deliveryMode)

setExpiration

public MessageBuilderSupport<T> setExpiration(String expiration)

setPriority

public MessageBuilderSupport<T> setPriority(Integer priority)

setReceivedExchange

public MessageBuilderSupport<T> setReceivedExchange(String receivedExchange)

setReceivedRoutingKey

public MessageBuilderSupport<T> setReceivedRoutingKey(String receivedRoutingKey)

setRedelivered

public MessageBuilderSupport<T> setRedelivered(Boolean redelivered)

setDeliveryTag

public MessageBuilderSupport<T> setDeliveryTag(Long deliveryTag)

setMessageCount

public MessageBuilderSupport<T> setMessageCount(Integer messageCount)

setHeaderIfAbsent

public MessageBuilderSupport<T> setHeaderIfAbsent(String key,
 Object value)

setTimestampIfAbsent

public MessageBuilderSupport<T> setTimestampIfAbsent(Date timestamp)

setMessageIdIfAbsent

public MessageBuilderSupport<T> setMessageIdIfAbsent(String messageId)

setUserIdIfAbsent

public MessageBuilderSupport<T> setUserIdIfAbsent(String userId)

setAppIdIfAbsent

public MessageBuilderSupport<T> setAppIdIfAbsent(String appId)

setClusterIdIfAbsent

public MessageBuilderSupport<T> setClusterIdIfAbsent(String clusterId)

setTypeIfAbsent

public MessageBuilderSupport<T> setTypeIfAbsent(String type)

setCorrelationIdIfAbsent

public MessageBuilderSupport<T> setCorrelationIdIfAbsent(String correlationId)

setReplyToIfAbsent

public MessageBuilderSupport<T> setReplyToIfAbsent(String replyTo)

setReplyToAddressIfAbsent

public MessageBuilderSupport<T> setReplyToAddressIfAbsent(Address replyTo)

setContentTypeIfAbsentOrDefault

public MessageBuilderSupport<T> setContentTypeIfAbsentOrDefault(String contentType)

setContentEncodingIfAbsent

public MessageBuilderSupport<T> setContentEncodingIfAbsent(String contentEncoding)

setContentLengthIfAbsent

public MessageBuilderSupport<T> setContentLengthIfAbsent(long contentLength)

setDeliveryModeIfAbsentOrDefault

public MessageBuilderSupport<T> setDeliveryModeIfAbsentOrDefault(MessageDeliveryMode deliveryMode)

setExpirationIfAbsent

public MessageBuilderSupport<T> setExpirationIfAbsent(String expiration)

setPriorityIfAbsentOrDefault

public MessageBuilderSupport<T> setPriorityIfAbsentOrDefault(Integer priority)

setReceivedExchangeIfAbsent

public MessageBuilderSupport<T> setReceivedExchangeIfAbsent(String receivedExchange)

setReceivedRoutingKeyIfAbsent

public MessageBuilderSupport<T> setReceivedRoutingKeyIfAbsent(String receivedRoutingKey)

setRedeliveredIfAbsent

public MessageBuilderSupport<T> setRedeliveredIfAbsent(Boolean redelivered)

setDeliveryTagIfAbsent

public MessageBuilderSupport<T> setDeliveryTagIfAbsent(Long deliveryTag)

setMessageCountIfAbsent

public MessageBuilderSupport<T> setMessageCountIfAbsent(Integer messageCount)

copyProperties

public MessageBuilderSupport<T> copyProperties(MessageProperties properties)

copyHeaders

public MessageBuilderSupport<T> copyHeaders(Map<String,Object> headers)

copyHeadersIfAbsent

public MessageBuilderSupport<T> copyHeadersIfAbsent(Map<String,Object> headers)

removeHeader

public MessageBuilderSupport<T> removeHeader(String key)

removeHeaders

public MessageBuilderSupport<T> removeHeaders()

buildProperties

protected MessageProperties buildProperties()

build

public abstract T build()