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