Struct ConsumerRuntime 

#[non_exhaustive]
pub struct ConsumerRuntime {
    pub transport: Arc<dyn MessageTransport>,
    pub container: Arc<FrozenDiContainer>,
    pub poll: Duration,
    pub batch: usize,
    pub max_retries: u32,
    pub dedupe_ttl_secs: u64,
    pub concurrency: usize,
}

Drives one transport against the link-time handler registry.

Spawn from ArclyPlugin::on_start. The dispatch map is frozen at spawn — the polling loop performs immutable HashMap reads only.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

transport: Arc<dyn MessageTransport>

container: Arc<FrozenDiContainer>

poll: Duration

batch: usize

max_retries: u32

Failed deliveries per message before dead-lettering.

dedupe_ttl_secs: u64

TTL for the consume-side dedupe claim (when an IdempotencyStore is available in the DI container).

concurrency: usize

Messages processed concurrently per polled batch. 0/1 keeps the historical strictly-ordered sequential behaviour; higher values trade cross-message ordering within a batch for throughput (per-message dedupe and retries are unaffected — attempts is a sharded map).

Implementations

impl ConsumerRuntime

pub fn new( transport: Arc<dyn MessageTransport>, container: Arc<FrozenDiContainer>, ) -> Self

Sensible defaults: 300ms poll, batch 32, 3 retries, 1h dedupe TTL, sequential processing. Chain setters to adjust.

pub fn poll(self, v: Duration) -> Self

pub fn batch(self, v: usize) -> Self

pub fn max_retries(self, v: u32) -> Self

pub fn dedupe_ttl_secs(self, v: u64) -> Self

pub fn concurrency(self, v: usize) -> Self

pub fn spawn(self)