Package | Description |
---|---|
io.openmessaging.extension | |
io.openmessaging.message |
Modifier and Type | Method and Description |
---|---|
ExtensionHeader |
ExtensionHeader.setCorrelationId(String correlationId)
A client can use the
CORRELATION_ID field to link one message with another. |
ExtensionHeader |
ExtensionHeader.setDelayTime(long delayTime)
The
DELAY_TIME header field contains a number that represents the delayed times in milliseconds. |
ExtensionHeader |
ExtensionHeader.setExpireTime(long expireTime)
The
EXPIRE_TIME header field contains the expiration time, it represents a time-to-live value. |
ExtensionHeader |
ExtensionHeader.setMessageKey(String messageKey)
The
messagekey header field contains the custom key of a message. |
ExtensionHeader |
ExtensionHeader.setOffset(long offset)
This method is only called by the server.
|
ExtensionHeader |
ExtensionHeader.setPartition(int partition)
The
PARTITION in extension header field contains the partition of target destination which the message
is being sent. |
ExtensionHeader |
ExtensionHeader.setStoreHost(String storeHost)
The
STORE_HOST header field contains the store host info of a message in server side. |
ExtensionHeader |
ExtensionHeader.setStoreTimestamp(long storeTimestamp)
The
STORE_TIMESTAMP header field contains the store timestamp of a message in server side. |
ExtensionHeader |
ExtensionHeader.setTraceId(String traceId)
The
TRACE_ID header field contains the trace ID of a message, which represents a global and unique
identification, to associate key events in the whole lifecycle of a message, like sent by who, stored at where,
and received by who. |
ExtensionHeader |
ExtensionHeader.setTransactionId(String transactionId)
This field
TRANSACTION_ID is used in transactional message, and it can be used to trace a transaction. |
Modifier and Type | Method and Description |
---|---|
ExtensionHeader |
Message.extensionHeader()
This interface is optional, Therefore, users need to check whether the interface is implemented and the
correctness of its implementation.
|
Copyright © 2017–2020 OpenMessaging. All rights reserved.