Class Debouncer

constructor

• new Debouncer(options): Debouncer

• Creates debouncer. See createInputConsumer on how to listen for input messages. See dispatchStoredMessages on how to send messages to the output queue (e.g. from a cron trigger).

  Parameters

  • options: DebouncerOptions

  Returns Debouncer

inputQueueUrl

outputQueueUrl

sqs

createInputConsumer

• createInputConsumer(): Consumer

• Use this consumer to start processing messages on your input queue. Example:

  const consumer = debouncer.createInputConsumer();
  consumer.start()
  Copy

  Returns Consumer

dispatchStoredMessages

• dispatchStoredMessages(): Promise<void>

• Call this method at the rate you wish to debounce events. Example:

  // Runs every hour at the start of the hour
  cron.schedule("0 * * * *", async () => {
      // Push out all deduped messages received so far
      debouncer.dispatchStoredMessages();
  });
  Copy

  Returns Promise<void>

enqueue

• enqueue(messages, queueUrl): Promise<void>

• Parameters

  • messages: MessagePayload[]
  • queueUrl: string

  Returns Promise<void>