Struct RedisConsumer 

pub struct RedisConsumer { /* private fields */ }

Redis consumer implementation supporting both Pub/Sub and Queue modes.

Implementations

impl RedisConsumer

pub fn new(config: RedisEndpointConfig) -> Self

Creates a new RedisConsumer with the given configuration.

The mode is automatically determined from the command type in the config:

• SUBSCRIBE → PubSub with channels
• PSUBSCRIBE → PubSub with patterns
• BLPOP/BRPOP → Queue mode

Trait Implementations

impl Consumer for RedisConsumer

fn concurrency_model(&self) -> ConcurrencyModel

Redis consumers are sequential by default to maintain message order.

This default is chosen for the following reasons:

• Pub/Sub: Messages often need ordering (e.g., event streams, notifications)
• Queue (BLPOP): Queue items should be processed in order
• Backpressure: Sequential processing naturally applies backpressure when the consumer is slower than the producer

Users can override this with .concurrent(n) in the route DSL if they want parallel processing and ordering is not a concern.

fn start<'life0, 'async_trait>( &'life0 mut self, ctx: ConsumerContext, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start consuming messages, sending them through the provided context.

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop consuming messages.