Java
OutboxEntry
代表收件箱(Outbox)中待发送的持久化消息。
业务事务中将领域事件写入 OutboxStore,由 OutboxPublisher
异地轮询并以至少一次的方式投递到消息总线。
- Type class
- Package:
com.euonia.bus.consistency - Author: damon(zhaorong@outlook.com)
Methods¶
getMessageId(): String¶
Returns: String — 消息唯一标识符
setMessageId(String messageId): void¶
Parameters:
- messageId (String): 消息唯一标识符
getChannel(): String¶
Returns: String — 消息所属通道
setChannel(String channel): void¶
Parameters:
- channel (String): 消息所属通道
getMessageType(): String¶
Returns: String — 消息类型名称
setMessageType(String messageType): void¶
Parameters:
- messageType (String): 消息类型名称
getContent(): MessageEnvelope<?>¶
Returns: MessageEnvelope<?> — 消息内容(负载)
setContent(MessageEnvelope<?> content): void¶
Parameters:
- content (MessageEnvelope<?>): 消息内容(负载)
getCreatedAt(): LocalDateTime¶
Returns: LocalDateTime — 条目创建时间
setCreatedAt(LocalDateTime createdAt): void¶
Parameters:
- createdAt (LocalDateTime): 条目创建时间
getTransports(): List<OutboxTransport>¶
Returns: List<OutboxTransport> — 关联的传输状态列表
setTransports(List<OutboxTransport> transports): void¶
Parameters:
- transports (List<OutboxTransport>): 关联的传输状态列表
addTransport(OutboxTransport transport): void¶
添加一条传输状态记录。
Parameters:
- transport (OutboxTransport): 传输状态
addTransports(String transport): void¶
按传输名称添加传输记录(当前为空实现)。
Parameters:
- transport (String): 传输名称
toString(): String¶
返回投递箱条目的字符串表示。
Returns: String — 格式为 OutboxMessage{messageId=xxx, channel=xxx} 的字符串