edgeport - v1.0.3
    Preparing search index...

    Interface JsMessage

    A single message pulled from a durable consumer.

    Call ack once the message is fully processed; until then it stays un-acked and the server will redeliver it after the consumer's ack-wait. That is the no-loss guarantee: a crash before ack means the message comes back; a successful ack means it never does.

    1.0.0

    interface JsMessage {
        data: Uint8Array;
        replyTo: string;
        subject: string;
        ack(): Promise<void>;
    }
    Index
    data replyTo subject
    ack
    data: Uint8Array

    The raw payload bytes.

    replyTo: string

    The reply subject the ack is published to (the JetStream ack inbox).

    subject: string

    The original subject the message was published to.

    • Acknowledges the message, removing it from redelivery. Uses a confirmed (double) ack: it awaits the server's acknowledgement so the ack is durable before it resolves - safe to reconnect or close immediately after.

      Returns Promise<void>

      Resolves once the server has confirmed the ack.

      If the server does not confirm the ack in time.

    Settings
    Member Visibility

    On This Page
    Properties
    Methods