Stratal API Reference
    Preparing search index...

    Interface IQueueProvider

    Queue Provider Interface

    Defines the contract for queue providers. Each provider handles the actual message delivery mechanism.

    Available Providers:

    • cloudflare: Uses Cloudflare Queue bindings (production)
    • sync: Processes messages immediately (testing/development)
    export class CustomQueueProvider implements IQueueProvider {
      async send<T>(queueName: string, message: QueueMessage<T>): Promise<void> {
        // Custom implementation
      }
    }
    interface IQueueProvider {
        send<T>(queueName: string, message: QueueMessage<T>): Promise<void>;
    }

    Implemented by

    Index

    Methods

    send

    Methods

    • Send a message to a queue

      Provider handles the actual delivery mechanism:

      • CloudflareQueueProvider: Resolves CF binding and calls queue.send()
      • SyncQueueProvider: Finds matching consumers and calls handle() directly

      Type Parameters

      • T

      Parameters

      • queueName: string

        Queue name

      • message: QueueMessage<T>

        Complete message with id, timestamp, and metadata

      Returns Promise<void>

    Settings

    Member Visibility

    On This Page

    Methods