public class IntegrationMessageHeaderAccessor extends MessageHeaderAccessor
| 修飾子と型 | フィールドと説明 |
|---|---|
static StringSE | ACKNOWLEDGMENT_CALLBACK メッセージ配信を確認するためのコールバック。 |
static StringSE | CLOSEABLE_RESOURCE |
static StringSE | CORRELATION_ID |
static StringSE | DELIVERY_ATTEMPT |
static StringSE | DUPLICATE_MESSAGE |
static StringSE | EXPIRATION_DATE |
static StringSE | PRIORITY |
static StringSE | ROUTING_SLIP |
static StringSE | SEQUENCE_DETAILS |
static StringSE | SEQUENCE_NUMBER |
static StringSE | SEQUENCE_SIZE |
static StringSE | SOURCE_DATA 生のソースメッセージ。 |
DEFAULT_CHARSET| コンストラクターと説明 |
|---|
IntegrationMessageHeaderAccessor(Message<?> message) |
| 修飾子と型 | メソッドと説明 |
|---|---|
AcknowledgmentCallback | getAcknowledgmentCallback() 存在する場合は、確認応答コールバックを返します。 |
CloseableSE | getCloseableResource() ペイロードが消費されるまで開いたままにする必要がある CloseableSE によってペイロードが作成された場合、リソースはこのヘッダーに追加されます。 |
ObjectSE | getCorrelationId() |
AtomicIntegerSE | getDeliveryAttempt() メッセージ駆動型エンドポイントが暗黙的に再試行をサポートしている場合、このヘッダーは配信が試行されるたびにインクリメントされます。 |
LongSE | getExpirationDate() |
<T> T | getHeader(StringSE key, ClassSE<T> type) |
IntegerSE | getPriority() |
int | getSequenceNumber() |
int | getSequenceSize() |
<T> T | getSourceData() 存在する場合は、ソースデータヘッダーを取得します。 |
boolean | isReadOnly(StringSE headerName) |
void | setReadOnlyHeaders(StringSE... readOnlyHeaders) 読み取り専用と見なし、メッセージへの入力を禁止するヘッダーのリストを指定します。 |
MapSE<StringSE, ObjectSE> | toMap() |
protected void | verifyType(StringSE headerName, ObjectSE headerValue) |
copyHeaders, copyHeadersIfAbsent, createAccessor, getAccessor, getAccessor, getAccessor, getContentType, getDetailedLogMessage, getDetailedPayloadLogMessage, getErrorChannel, getHeader, getId, getMessageHeaders, getMutableAccessor, getReplyChannel, getShortLogMessage, getShortPayloadLogMessage, getTimestamp, isModified, isMutable, isReadableContentType, removeHeader, removeHeaders, setContentType, setErrorChannel, setErrorChannelName, setHeader, setHeaderIfAbsent, setImmutable, setLeaveMutable, setModified, setReplyChannel, setReplyChannelName, toMessageHeaders, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic static final StringSE ACKNOWLEDGMENT_CALLBACK
public void setReadOnlyHeaders(StringSE... readOnlyHeaders)
readOnlyHeaders - readOnly モードのヘッダーのリスト。デフォルトは MessageHeaders.ID および MessageHeaders.TIMESTAMP です。isReadOnly(String)public int getSequenceNumber()
public int getSequenceSize()
@Nullable public CloseableSE getCloseableResource()
CloseableSE によってペイロードが作成された場合、リソースはこのヘッダーに追加されます。ペイロードが消費された後、CloseableSE を閉じる必要があります。通常、これはフロー内のメッセージ発信元に近いエンドポイントで、同じ JVM で発生する必要があります。CloseableSE@Nullable public AcknowledgmentCallback getAcknowledgmentCallback()
@Nullable public AtomicIntegerSE getDeliveryAttempt()
@Nullable public <T> T getSourceData()
T - データ型。protected void verifyType(StringSE headerName, ObjectSE headerValue)
MessageHeaderAccessor の verifyType public boolean isReadOnly(StringSE headerName)
MessageHeaderAccessor の isReadOnly public MapSE<StringSE,ObjectSE> toMap()
MessageHeaderAccessor の toMap