Interface TransportMessage<T>

A message arriving on a topic.

interface TransportMessage<T = unknown> {
    messageId: string;
    payload: T;
    senderId: string;
    timestamp: number;
    topic: string;
}

Properties

messageId: string

Per-message id; receivers can dedup against this.

payload: T

Decoded application payload.

senderId: string

App-level identity of the sender.

timestamp: number

Sender-side ms timestamp; best-effort ordering only.

topic: string

App-level routing key the message arrived on.