Interface AsyncMessage

May be received after creating a consumer with Channel.basicConsume

interface AsyncMessage {
    appId?: string;
    body: any;
    clusterId?: string;
    consumerTag: string;
    contentEncoding?: string;
    contentType?: string;
    correlationId?: string;
    deliveryTag: number;
    durable?: boolean;
    exchange: string;
    expiration?: string;
    headers?: {
        BCC?: string[];
        CC?: string[];
        [k: string]: any;
    };
    messageId?: string;
    priority?: number;
    redelivered: boolean;
    replyTo?: string;
    routingKey: string;
    timestamp?: number;
    type?: string;
    userId?: string;
}

Hierarchy (view full)

Properties

appId? body clusterId? consumerTag contentEncoding? contentType? correlationId? deliveryTag durable? exchange expiration? headers? messageId? priority? redelivered replyTo? routingKey timestamp? type? userId?

Properties

OptionalappId

appId?: string

Creating application id.

body

body: any

OptionalclusterId

clusterId?: string

consumerTag

consumerTag: string

Identifier for the consumer, valid within the current channel.

OptionalcontentEncoding

contentEncoding?: string

MIME content encoding. e.g. "gzip"

OptionalcontentType

contentType?: string

MIME content type. e.g. "application/json"

OptionalcorrelationId

correlationId?: string

Application correlation identifier.

deliveryTag

deliveryTag: number

The server-assigned and channel-specific delivery tag

Optionaldurable

durable?: boolean

Alias for "deliveryMode". Published message should be saved to disk and should survive server restarts.

exchange

exchange: string

Specifies the name of the exchange that the message was originally published to. May be empty, indicating the default exchange.

Optionalexpiration

expiration?: string

Message TTL, in milliseconds. Note that only when expired messages reach the head of a queue will they actually be discarded (or dead-lettered). Setting the TTL to 0 causes messages to be expired upon reaching a queue unless they can be delivered to a consumer immediately.

Optionalheaders

headers?: {
    BCC?: string[];
    CC?: string[];
    [k: string]: any;
}

Additional user-defined fields

Type declaration

OptionalmessageId

messageId?: string

Application message identifier.

Optionalpriority

priority?: number

Message priority, 0 to 9.

redelivered

redelivered: boolean

True if the message has been previously delivered to this or another client.

OptionalreplyTo

replyTo?: string

https://www.rabbitmq.com/direct-reply-to.html

routingKey

routingKey: string

The routing key name specified when the message was published.

Optionaltimestamp

timestamp?: number

Message timestamp in seconds.

Optionaltype

type?: string

Message type name.

OptionaluserId

userId?: string

Creating user id.

Settings

Member Visibility

On This Page

Properties