Skip to content

fmacias/tplqueue-core-public

v0.1.0MIT

Public TplQueue.Core consumption workflows for the factory facade, queue lifecycle, observation, retry behavior, CacheQ semantics, and DataJob/Payload usage without exposing private implementation details.

configure-core-retry-behavior

Explain or review TplQueue.Core root-versus-queue retry selection, explicit NoRetry, null policy results, Job identity, RetryCount, cancellation, execution channels, and policy-factory failures. Adapter named policy registration and DI remain outside this workflow.

observe-core-job-lifecycle

Guide TplQueue consumers observing IQ.Subscribe and observable Job events, including asynchronous snapshots, OnNext versus OnError, slow observers, ordering, WaitAsync limits, and optional execution-channel metadata.

review-core-public-surface

Review TplQueue.Core public package architecture, factory boundaries, and consumer-visible runtime semantics for compatibility and accidental exposure of private implementation knowledge. Use for public Core API or usage guidance reviews, not private implementation development.

use-core-cacheq-semantics

Explain or review public CacheQ construction and payload-aware consumption, asynchronous terminal cache transitions, observer latency, WaitAsync and disposal limits, and unsupported durability or leasing-timing assumptions.

use-core-datajob-payload

Guide current TplQueue.Core IDataJob and IDataJobRoot construction through IDataJobFactory, IPayload identity and HandlerKey routing, IHandler responsibility, and supported rehydration, retry, and CacheQ relationships.

use-core-factory-facade

Guide TplQueue.Core consumers through CoreApi.Create, ICoreApi, and public queue, Job, and DataJob factories, including construction boundaries and lifetime assumptions. Use for Core construction API usage; Adapter DI configuration belongs to tplqueue-adapter.

use-core-queue-lifecycle

Explain or review TplQueue.Core ParallelQ, FifoQ, and CacheQ consumer lifecycle semantics, including bounded execution, Pause, ResumePolling, WaitAsync, cancellation, fatal queue state, and disposal.