* Add a message to the queue. * Preserves muxMetadata from first message, updates other options. * Accumulates file parts. * * @throws Error if trying to add a compaction request when queue already has messages
(
message: string,
options?: SendMessageOptions & { fileParts?: FilePart[] },
internal?: QueuedMessageInternalOptions
)
| 137 | * @throws Error if trying to add a compaction request when queue already has messages |
| 138 | */ |
| 139 | add( |
| 140 | message: string, |
| 141 | options?: SendMessageOptions & { fileParts?: FilePart[] }, |
| 142 | internal?: QueuedMessageInternalOptions |
| 143 | ): boolean { |
| 144 | return this.addInternal(message, options, internal); |
| 145 | } |
| 146 | |
| 147 | /** |
| 148 | * Add a message to the queue once, keyed by dedupeKey. |