Interface QueueMessage

A message fetched from the queue, with additional fields for message count, delivery tag, redelivery status, exchange, and routing key.

Hierarchy

  • GetMessage
    • QueueMessage

Properties

content: Buffer

The content of the message as a Buffer.

fields: {
    deliveryTag: number;
    exchange: string;
    messageCount: number;
    redelivered: boolean;
    routingKey: string;
}

An object containing additional fields for message count, delivery tag, redelivery status, exchange, and routing key.

Type declaration

  • deliveryTag: number

    The delivery tag of the message.

  • exchange: string

    The exchange the message was published to.

  • messageCount: number

    The number of messages in the queue.

  • redelivered: boolean

    Whether the message has been redelivered.

  • routingKey: string

    The routing key used to publish the message.

properties: {
    appId: any;
    clusterId: any;
    contentEncoding: any;
    contentType: any;
    correlationId: any;
    deliveryMode: any;
    expiration: any;
    headers: {
        x-death?: XDeath[];
        x-first-death-exchange?: string;
        x-first-death-queue?: string;
        x-first-death-reason?: string;
        [key: string]: any;
    };
    messageId: any;
    priority: any;
    replyTo: any;
    timestamp: any;
    type: any;
    userId: any;
}

An object containing additional properties for the message.

Type declaration

  • appId: any

    The application ID of the message.

  • clusterId: any

    The cluster ID of the message.

  • contentEncoding: any

    The content encoding of the message.

  • contentType: any

    The content type of the message.

  • correlationId: any

    The correlation ID of the message.

  • deliveryMode: any

    The delivery mode of the message.

  • expiration: any

    The expiration time of the message.

  • headers: {
        x-death?: XDeath[];
        x-first-death-exchange?: string;
        x-first-death-queue?: string;
        x-first-death-reason?: string;
        [key: string]: any;
    }

    The headers of the message.

    • [key: string]: any
    • Optional x-death?: XDeath[]

      The time the message was first published.

    • Optional x-first-death-exchange?: string

      The number of times the message has been redelivered.

    • Optional x-first-death-queue?: string

      The exchange the message was published to.

    • Optional x-first-death-reason?: string

      The routing key used to publish the message.

  • messageId: any

    The message ID.

  • priority: any

    The priority of the message.

  • replyTo: any

    The reply-to address for the message.

  • timestamp: any

    The timestamp of the message.

  • type: any

    The type of the message.

  • userId: any

    The user ID of the message sender.