UNPKG

898 BTypeScriptView Raw
1/**
2 * @publicApi
3 */
4export 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 * @publicApi
23 */
24export declare class RmqRecord<TData = any> {
25 readonly data: TData;
26 options?: RmqRecordOptions;
27 constructor(data: TData, options?: RmqRecordOptions);
28}
29/**
30 * @publicApi
31 */
32export 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}