INNER CODE UNIT · TypeScript

queueEventDispatcher

cloudflare/miniflare · packages/core/src/index.ts:420

    const queueEventDispatcher = async (batch: MessageBatch) => {
      await this.dispatchQueue(batch);

      // TODO(soon) detect success vs failure during processing
      this.#ctx.log.info(
        `${batch.queue} (${batch.messages.length} Messages) OK`
      );
    };

    const ctx: PluginContext = {
      log: this.#ctx.log,
      compat: this.#compat,
      rootPath,
      usageModel,
      globalAsyncIO,
      fetchMock,
      queueEventDispatcher,
      queueBroker,

View source record →