| 1 | export interface RmqUrl {
|
| 2 | protocol?: string;
|
| 3 | hostname?: string;
|
| 4 | port?: number;
|
| 5 | username?: string;
|
| 6 | password?: string;
|
| 7 | locale?: string;
|
| 8 | frameMax?: number;
|
| 9 | heartbeat?: number;
|
| 10 | vhost?: string;
|
| 11 | }
|
| 12 | export interface AmqpConnectionManagerSocketOptions {
|
| 13 | reconnectTimeInSeconds?: number;
|
| 14 | heartbeatIntervalInSeconds?: number;
|
| 15 | findServers?: () => string | string[];
|
| 16 | connectionOptions?: any;
|
| 17 | }
|
| 18 | export interface AmqplibQueueOptions {
|
| 19 | durable?: boolean;
|
| 20 | autoDelete?: boolean;
|
| 21 | arguments?: any;
|
| 22 | messageTtl?: number;
|
| 23 | expires?: number;
|
| 24 | deadLetterExchange?: string;
|
| 25 | deadLetterRoutingKey?: string;
|
| 26 | maxLength?: number;
|
| 27 | maxPriority?: number;
|
| 28 | }
|