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 buildingMessage
andMessageProperties
fluent API.- Since:
- 1.3
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
MessageBuilderSupport()
protected
MessageBuilderSupport(MessageProperties properties)
-
Method Summary
-
-
-
Constructor Detail
-
MessageBuilderSupport
protected MessageBuilderSupport()
-
MessageBuilderSupport
protected MessageBuilderSupport(MessageProperties properties)
-
-
Method Detail
-
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()
-
-