Trait ConsumerRegistrar 

pub trait ConsumerRegistrar: Send + Sync {
    // Required method
    fn consumers(
        &self,
        startup: &GenericStartup,
    ) -> Vec<Box<dyn QueueDescriptor>>;
}

Builds the queue consumers to record during bootstrap.

Receives &GenericStartup so consumers can be constructed from startup state such as the environment, gateway, or Redis handle.

Required Methods

fn consumers(&self, startup: &GenericStartup) -> Vec<Box<dyn QueueDescriptor>>

Returns the consumer descriptors to record, one entry per queue.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors