Interface MessageQueueOptions<TMessage>

Delay before a batch insert.

With bestEffort: true (default),

• batches are inserted with write concern majority,
• the BatchPublisher will emit error events on write failures,
• retry inserting messages,
• and attempt a bulk insert on closure.

With bestEffort: false,

• batches are inserted with write concern 0,
• no errors will be emitted on failures,
• and unwritten messages will be dropped in case of failure or closure.

Maximum number of messages to be consumed concurrently for this Consumer. Defaults to 1.

Maximum follow-up polling delay in milliseconds. Consumers will fast-poll while concurrency is not reached, and after a message is successfully consumed. Defaults to 10 milliseconds.

Global MongoDB filter to apply on change stream.

Consumer group. Defaults to the collection name.

Maximum number of messages per batch to bulk insert.

Maximum number of retries per message. Defaults to 1.

Maximum number of seconds to poll for past messages to consume. Defaults to 3600 seconds (1 hour).

Polling interval in milliseconds. Defaults to 1000 milliseconds.

Minimum number of seconds before a published message may be consumed. Defaults to zero.

Minimum number of seconds to hide messages from other consumers after receiving. Set at least to 2x of the maximum workload time for message consumption. Defaults to 2 seconds.