public class MessageExtensionHeaderAdapter extends Object implements io.openmessaging.extension.ExtensionHeader
| 构造器和说明 |
|---|
MessageExtensionHeaderAdapter(ConsumeMessage message) |
| 限定符和类型 | 方法和说明 |
|---|---|
String |
getCorrelationId() |
long |
getDelayTime() |
long |
getExpireTime() |
String |
getMessageKey() |
long |
getOffset() |
int |
getPartiton() |
String |
getStoreHost() |
long |
getStoreTimestamp() |
String |
getTraceId() |
String |
getTransactionId() |
io.openmessaging.extension.ExtensionHeader |
setCorrelationId(String correlationId) |
io.openmessaging.extension.ExtensionHeader |
setDelayTime(long delayTime) |
io.openmessaging.extension.ExtensionHeader |
setExpireTime(long expireTime) |
io.openmessaging.extension.ExtensionHeader |
setMessageKey(String messageKey) |
io.openmessaging.extension.ExtensionHeader |
setOffset(long offset) |
io.openmessaging.extension.ExtensionHeader |
setPartition(int partition) |
io.openmessaging.extension.ExtensionHeader |
setStoreHost(String storeHost) |
io.openmessaging.extension.ExtensionHeader |
setStoreTimestamp(long storeTimestamp) |
io.openmessaging.extension.ExtensionHeader |
setTraceId(String traceId) |
io.openmessaging.extension.ExtensionHeader |
setTransactionId(String transactionId) |
String |
toString() |
public MessageExtensionHeaderAdapter(ConsumeMessage message)
public io.openmessaging.extension.ExtensionHeader setPartition(int partition)
setPartition 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setOffset(long offset)
setOffset 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setCorrelationId(String correlationId)
setCorrelationId 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setTransactionId(String transactionId)
setTransactionId 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setStoreTimestamp(long storeTimestamp)
setStoreTimestamp 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setStoreHost(String storeHost)
setStoreHost 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setMessageKey(String messageKey)
setMessageKey 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setTraceId(String traceId)
setTraceId 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setDelayTime(long delayTime)
setDelayTime 在接口中 io.openmessaging.extension.ExtensionHeaderpublic io.openmessaging.extension.ExtensionHeader setExpireTime(long expireTime)
setExpireTime 在接口中 io.openmessaging.extension.ExtensionHeaderpublic int getPartiton()
getPartiton 在接口中 io.openmessaging.extension.ExtensionHeaderpublic long getOffset()
getOffset 在接口中 io.openmessaging.extension.ExtensionHeaderpublic String getCorrelationId()
getCorrelationId 在接口中 io.openmessaging.extension.ExtensionHeaderpublic String getTransactionId()
getTransactionId 在接口中 io.openmessaging.extension.ExtensionHeaderpublic long getStoreTimestamp()
getStoreTimestamp 在接口中 io.openmessaging.extension.ExtensionHeaderpublic String getStoreHost()
getStoreHost 在接口中 io.openmessaging.extension.ExtensionHeaderpublic long getDelayTime()
getDelayTime 在接口中 io.openmessaging.extension.ExtensionHeaderpublic long getExpireTime()
getExpireTime 在接口中 io.openmessaging.extension.ExtensionHeaderpublic String getMessageKey()
getMessageKey 在接口中 io.openmessaging.extension.ExtensionHeaderpublic String getTraceId()
getTraceId 在接口中 io.openmessaging.extension.ExtensionHeaderCopyright © 2020 Joyqueue Community. All rights reserved.