Type Alias HotMeshWorker

HotMeshWorker: {
    callback: ((payload: StreamData) => Promise<StreamDataResponse>);
    connection?: ProviderConfig | ProvidersConfig;
    reclaimCount?: number;
    reclaimDelay?: number;
    taskQueue?: string;
    topic: string;
}

Type declaration

  • callback: ((payload: StreamData) => Promise<StreamDataResponse>)

    The callback function to execute when a message is dequeued from the target stream

  • Optionalconnection?: ProviderConfig | ProvidersConfig

    short-form format for the connection options for the store, stream, sub, and search clients

  • OptionalreclaimCount?: number

    the number of times to reclaim a stream before giving up and moving the message to a dead-letter queue or other error handling mechanism

  • OptionalreclaimDelay?: number

    the number of milliseconds to wait before reclaiming a stream; depending upon the provider this may be an explicit retry event, consuming a message from the stream and re-queueing it (dlq, etc), or it may be a configurable delay before the provider exposes the message to the consumer again. It is up to the provider, but expressed in milliseconds here.

  • OptionaltaskQueue?: string

    Task queue identifier used for connection pooling optimization. When provided, connections will be reused across providers (store, sub, stream) that share the same task queue and database configuration.

  • topic: string

    the topic that the worker subscribes to

Settings

Member Visibility