public abstract class RocketMQMessage<KEY,MESSAGE_ID> extends Object implements Serializable
| 限定符和类型 | 字段和说明 |
|---|---|
private Object |
content |
private KEY |
key |
private MESSAGE_ID |
messageId |
private Integer |
retryTimes |
private LocalDateTime |
sendTime |
private static long |
serialVersionUID |
private Object |
source |
private String |
traceId |
| 限定符 | 构造器和说明 |
|---|---|
protected |
RocketMQMessage() |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
equals(Object obj) |
Object |
getContent() |
KEY |
getKey() |
MESSAGE_ID |
getMessageId() |
Integer |
getRetryTimes() |
LocalDateTime |
getSendTime() |
Object |
getSource() |
String |
getTraceId() |
int |
hashCode() |
RocketMQMessage<KEY,MESSAGE_ID> |
setContent(Object content) |
RocketMQMessage<KEY,MESSAGE_ID> |
setKey(KEY key) |
void |
setMessageId(MESSAGE_ID messageId) |
RocketMQMessage<KEY,MESSAGE_ID> |
setRetryTimes(Integer retryTimes) |
RocketMQMessage<KEY,MESSAGE_ID> |
setSendTime(LocalDateTime sendTime) |
RocketMQMessage<KEY,MESSAGE_ID> |
setSource(Object source) |
RocketMQMessage<KEY,MESSAGE_ID> |
setTraceId(String traceId) |
String |
toString() |
private static final long serialVersionUID
private MESSAGE_ID messageId
private KEY key
private Object source
private LocalDateTime sendTime
private String traceId
private Integer retryTimes
private Object content
public MESSAGE_ID getMessageId()
public void setMessageId(MESSAGE_ID messageId)
public KEY getKey()
public RocketMQMessage<KEY,MESSAGE_ID> setKey(KEY key)
public Object getSource()
public RocketMQMessage<KEY,MESSAGE_ID> setSource(Object source)
public LocalDateTime getSendTime()
public RocketMQMessage<KEY,MESSAGE_ID> setSendTime(LocalDateTime sendTime)
public String getTraceId()
public RocketMQMessage<KEY,MESSAGE_ID> setTraceId(String traceId)
public Integer getRetryTimes()
public RocketMQMessage<KEY,MESSAGE_ID> setRetryTimes(Integer retryTimes)
public Object getContent()
public RocketMQMessage<KEY,MESSAGE_ID> setContent(Object content)
Copyright © 2025 Zodiac. All rights reserved.