Member Junction
    Preparing search index...

    Interface WorkMessage<TPayload>

    The message as delivered to a handler. Identical on every transport.

    interface WorkMessage<TPayload extends WorkJson = WorkJson> {
        Attributes: Record<string, string>;
        CorrelationID?: string;
        MessageID: string;
        PartitionKey?: string;
        Payload?: TPayload;
        PayloadRef?: WorkPayloadRef;
        PublishedAt: string;
        Topic: string;
    }

    Type Parameters

    Index

    Properties

    Attributes CorrelationID? MessageID PartitionKey? Payload? PayloadRef? PublishedAt Topic

    Properties

    Attributes: Record<string, string>

    ≤ 10 entries; keys 1–64 chars [A-Za-z0-9_-] (no dots: a dotted name is MJ's source.field filter form, which filters reject, so a dotted attribute would be unfilterable); values 1–256 chars (brokers refuse empty values). The only fields filters see.

    CorrelationID?: string
    MessageID: string

    UUID, globally unique (spec 03 §2.1). Stable across redeliveries and replays. Producer-supplied or generated at publish.

    PartitionKey?: string

    Ordering is publish order per key; there is no producer-supplied ordering number (spec 03 §1).

    Payload?: TPayload
    PayloadRef?: WorkPayloadRef
    PublishedAt: string

    ISO-8601 UTC, assigned by the publisher (MJ), not the producer.

    Topic: string

    Settings

    Member Visibility

    On This Page

    Properties