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} 的字符串