Struct Consumer 

pub struct Consumer { /* private fields */ }

Consumer for receiving messages from RabbitMQ

Implementations

impl Consumer

pub async fn new( connection_manager: ConnectionManager, options: ConsumerOptions, ) -> Result<Self>

Create a new consumer

pub fn set_metrics(&mut self, metrics: RustRabbitMetrics)

Set metrics for this consumer

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

where T: DeserializeOwned + Send + Sync + 'static, H: MessageHandler<T>,

Start consuming messages with the given handler

pub async fn stop(&self) -> Result<()>

Stop consuming (close the consumer)