Type Alias HotMeshEngine

HotMeshEngine: {
    connection?: ProviderConfig | ProvidersConfig;
    readonly?: boolean;
    reclaimCount?: number;
    reclaimDelay?: number;
    taskQueue?: string;
}

Type declaration

  • Optionalconnection?: ProviderConfig | ProvidersConfig

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

  • Optionalreadonly?: boolean

    if true, the engine will not route stream messages to the worker

    Default

    false
  • 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.

Settings

Member Visibility