interface RmqOptions {
transport?: Transport.RMQ
options?: {...}
}
Properties
| Property |
Description |
transport?: Transport.RMQ
|
|
options?: {
urls?: string[] | RmqUrl[];
queue?: string;
prefetchCount?: number;
isGlobalPrefetchCount?: boolean;
queueOptions?: AmqplibQueueOptions;
socketOptions?: AmqpConnectionManagerSocketOptions;
noAck?: boolean;
consumerTag?: string;
serializer?: Serializer;
deserializer?: Deserializer;
replyQueue?: string;
persistent?: boolean;
headers?: Record<string, string>;
noAssert?: boolean;
exchange?: string;
exchangeType?: 'direct' | 'fanout' | 'topic' | 'headers';
exchangeArguments?: Record<string, string>;
routingKey?: string;
wildcards?: boolean;
maxConnectionAttempts?: number;
}
|
|
