Struct Consumer 

pub struct Consumer { /* private fields */ }

Simplified Consumer for message consumption

Implementations

impl Consumer

pub fn builder( connection: Arc<Connection>, queue_name: impl Into<String>, ) -> ConsumerBuilder

Create a new consumer builder

pub async fn consume<T, H, Fut>( &self, handler: H, ) -> Result<(), RustRabbitError>

where T: DeserializeOwned + Send + Clone + Sync + 'static + Serialize, H: Fn(Message<T>) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send,

Start consuming messages

pub async fn consume_envelopes<T, H, Fut>( &self, handler: H, ) -> Result<(), RustRabbitError>

where T: DeserializeOwned + Send + Clone + Sync + 'static + Serialize, H: Fn(MessageEnvelope<T>) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send,

Start consuming message envelopes with full retry support