Interface QueueRmqOptions

interface QueueRmqOptions {
    consumerTag?: string;
    deserializer?: Deserializer<any, any>;
    headers?: Record<string, string>;
    isGlobalPrefetchCount?: boolean;
    maxConnectionAttempts?: number;
    noAck?: boolean;
    noAssert?: boolean;
    persistent?: boolean;
    prefetchCount?: number;
    queue?: string;
    queueOptions?: AssertQueue;
    replyQueue?: string;
    serializer?: Serializer<any, any>;
    socketOptions?: AmqpConnectionManagerOptions;
    urls?: string[] | RmqUrl[];
}

Hierarchy (View Summary)

Properties

consumerTag? deserializer? headers? isGlobalPrefetchCount? maxConnectionAttempts? noAck? noAssert? persistent? prefetchCount? queue? queueOptions? replyQueue? serializer? socketOptions? urls?

Properties

OptionalconsumerTag

consumerTag?: string

Optionaldeserializer

deserializer?: Deserializer<any, any>

Optionalheaders

headers?: Record<string, string>

OptionalisGlobalPrefetchCount

isGlobalPrefetchCount?: boolean

OptionalmaxConnectionAttempts

maxConnectionAttempts?: number

Maximum number of connection attempts. Applies only to the consumer configuration. -1 === infinite

Default

-1

OptionalnoAck

noAck?: boolean

OptionalnoAssert

noAssert?: boolean

Optionalpersistent

persistent?: boolean

OptionalprefetchCount

prefetchCount?: number

Optionalqueue

queue?: string

OptionalqueueOptions

queueOptions?: AssertQueue

OptionalreplyQueue

replyQueue?: string

Optionalserializer

serializer?: Serializer<any, any>

OptionalsocketOptions

socketOptions?: AmqpConnectionManagerOptions

Optionalurls

urls?: string[] | RmqUrl[]

Settings

Member Visibility

On This Page

Properties