Function rabbit_borough::consumer::consumer::consume

pub async fn consume<'_, '_>(
    config: &'_ JSONConfiguration, 
    handler: &'_ dyn Fn(&Delivery) -> HandleMessageResult
) -> HandleMessageResult

This is the function that the consuming is happening There are two (infinite) loops here, a. one around the consumer, which while the connection is healthy keeps dequeuing messages b. one that once the connection dies, restarts the whole process of getting a channel and setting up the consumer