public abstract class AbstractIntegrationMessageBuilder<T>
extends java.lang.Object
Constructor and Description |
---|
AbstractIntegrationMessageBuilder() |
Modifier and Type | Method and Description |
---|---|
abstract org.springframework.messaging.Message<T> |
build() |
abstract AbstractIntegrationMessageBuilder<T> |
copyHeaders(java.util.Map<java.lang.String,?> headersToCopy)
Copy the name-value pairs from the provided Map.
|
abstract AbstractIntegrationMessageBuilder<T> |
copyHeadersIfAbsent(java.util.Map<java.lang.String,?> headersToCopy)
Copy the name-value pairs from the provided Map.
|
protected abstract java.lang.Object |
getCorrelationId() |
abstract java.util.Map<java.lang.String,java.lang.Object> |
getHeaders() |
abstract T |
getPayload() |
protected abstract java.util.List<java.util.List<java.lang.Object>> |
getSequenceDetails() |
protected abstract java.lang.Object |
getSequenceNumber() |
protected abstract java.lang.Object |
getSequenceSize() |
AbstractIntegrationMessageBuilder<T> |
popSequenceDetails() |
AbstractIntegrationMessageBuilder<T> |
pushSequenceDetails(java.lang.Object correlationId,
int sequenceNumber,
int sequenceSize) |
abstract AbstractIntegrationMessageBuilder<T> |
removeHeader(java.lang.String headerName)
Remove the value for the given header name.
|
abstract AbstractIntegrationMessageBuilder<T> |
removeHeaders(java.lang.String... headerPatterns)
Removes all headers provided via array of 'headerPatterns'.
|
AbstractIntegrationMessageBuilder<T> |
setCorrelationId(java.lang.Object correlationId) |
AbstractIntegrationMessageBuilder<T> |
setErrorChannel(org.springframework.messaging.MessageChannel errorChannel) |
AbstractIntegrationMessageBuilder<T> |
setErrorChannelName(java.lang.String errorChannelName) |
AbstractIntegrationMessageBuilder<T> |
setExpirationDate(java.util.Date expirationDate) |
AbstractIntegrationMessageBuilder<T> |
setExpirationDate(java.lang.Long expirationDate) |
abstract AbstractIntegrationMessageBuilder<T> |
setHeader(java.lang.String headerName,
java.lang.Object headerValue)
Set the value for the given header name.
|
abstract AbstractIntegrationMessageBuilder<T> |
setHeaderIfAbsent(java.lang.String headerName,
java.lang.Object headerValue)
Set the value for the given header name only if the header name is not already associated with a value.
|
AbstractIntegrationMessageBuilder<T> |
setPriority(java.lang.Integer priority) |
AbstractIntegrationMessageBuilder<T> |
setReplyChannel(org.springframework.messaging.MessageChannel replyChannel) |
AbstractIntegrationMessageBuilder<T> |
setReplyChannelName(java.lang.String replyChannelName) |
AbstractIntegrationMessageBuilder<T> |
setSequenceNumber(java.lang.Integer sequenceNumber) |
AbstractIntegrationMessageBuilder<T> |
setSequenceSize(java.lang.Integer sequenceSize) |
public abstract T getPayload()
public abstract java.util.Map<java.lang.String,java.lang.Object> getHeaders()
public abstract AbstractIntegrationMessageBuilder<T> setHeader(java.lang.String headerName, @Nullable java.lang.Object headerValue)
null
, the header will be removed.headerName
- The header name.headerValue
- The header value.public abstract AbstractIntegrationMessageBuilder<T> setHeaderIfAbsent(java.lang.String headerName, java.lang.Object headerValue)
headerName
- The header name.headerValue
- The header value.public abstract AbstractIntegrationMessageBuilder<T> removeHeaders(java.lang.String... headerPatterns)
headerPatterns
- The header patterns.public abstract AbstractIntegrationMessageBuilder<T> removeHeader(java.lang.String headerName)
headerName
- The header name.public abstract AbstractIntegrationMessageBuilder<T> copyHeaders(@Nullable java.util.Map<java.lang.String,?> headersToCopy)
copyHeadersIfAbsent(Map)
to avoid overwriting values. Note that the 'id' and 'timestamp' header values
will never be overwritten.headersToCopy
- The headers to copy.MessageHeaders.ID
,
MessageHeaders.TIMESTAMP
public abstract AbstractIntegrationMessageBuilder<T> copyHeadersIfAbsent(@Nullable java.util.Map<java.lang.String,?> headersToCopy)
headersToCopy
- The headers to copy.public AbstractIntegrationMessageBuilder<T> setExpirationDate(java.lang.Long expirationDate)
public AbstractIntegrationMessageBuilder<T> setExpirationDate(java.util.Date expirationDate)
public AbstractIntegrationMessageBuilder<T> setCorrelationId(java.lang.Object correlationId)
public AbstractIntegrationMessageBuilder<T> pushSequenceDetails(java.lang.Object correlationId, int sequenceNumber, int sequenceSize)
public AbstractIntegrationMessageBuilder<T> popSequenceDetails()
protected abstract java.util.List<java.util.List<java.lang.Object>> getSequenceDetails()
protected abstract java.lang.Object getCorrelationId()
protected abstract java.lang.Object getSequenceNumber()
protected abstract java.lang.Object getSequenceSize()
public AbstractIntegrationMessageBuilder<T> setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)
public AbstractIntegrationMessageBuilder<T> setReplyChannelName(java.lang.String replyChannelName)
public AbstractIntegrationMessageBuilder<T> setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
public AbstractIntegrationMessageBuilder<T> setErrorChannelName(java.lang.String errorChannelName)
public AbstractIntegrationMessageBuilder<T> setSequenceNumber(java.lang.Integer sequenceNumber)
public AbstractIntegrationMessageBuilder<T> setSequenceSize(java.lang.Integer sequenceSize)
public AbstractIntegrationMessageBuilder<T> setPriority(java.lang.Integer priority)
public abstract org.springframework.messaging.Message<T> build()