1 |
|
2 |
|
3 |
|
4 | export interface RmqRecordOptions {
|
5 | expiration?: string | number;
|
6 | userId?: string;
|
7 | CC?: string | string[];
|
8 | mandatory?: boolean;
|
9 | persistent?: boolean;
|
10 | deliveryMode?: boolean | number;
|
11 | BCC?: string | string[];
|
12 | contentType?: string;
|
13 | contentEncoding?: string;
|
14 | headers?: Record<string, string>;
|
15 | priority?: number;
|
16 | messageId?: string;
|
17 | timestamp?: number;
|
18 | type?: string;
|
19 | appId?: string;
|
20 | }
|
21 |
|
22 |
|
23 |
|
24 | export declare class RmqRecord<TData = any> {
|
25 | readonly data: TData;
|
26 | options?: RmqRecordOptions;
|
27 | constructor(data: TData, options?: RmqRecordOptions);
|
28 | }
|
29 | /**
|
30 | * @publicApi
|
31 | */
|
32 | export declare class RmqRecordBuilder<TData> {
|
33 | private data?;
|
34 | private options?;
|
35 | constructor(data?: TData);
|
36 | setOptions(options: RmqRecordOptions): this;
|
37 | setData(data: TData): this;
|
38 | build(): RmqRecord;
|
39 | }
|