/** * @publicApi */ export interface MqttRecordOptions { /** * The QoS */ qos?: 0 | 1 | 2; /** * The retain flag */ retain?: boolean; /** * Whether or not mark a message as duplicate */ dup?: boolean; properties?: { payloadFormatIndicator?: number; messageExpiryInterval?: number; topicAlias?: string; responseTopic?: string; correlationData?: Buffer; userProperties?: Record; subscriptionIdentifier?: number; contentType?: string; }; } /** * @publicApi */ export declare class MqttRecord { readonly data: TData; options?: MqttRecordOptions; constructor(data: TData, options?: MqttRecordOptions); } /** * @publicApi */ export declare class MqttRecordBuilder { private data?; private options?; constructor(data?: TData); setData(data: TData): this; setQoS(qos: MqttRecordOptions['qos']): this; setRetain(retain: MqttRecordOptions['retain']): this; setDup(dup: MqttRecordOptions['dup']): this; setProperties(properties: MqttRecordOptions['properties']): this; build(): MqttRecord; }