lapin

lapin copied to clipboard

Add with_type() message property function

4

According to the AMQP 0.9.1 docs (https://www.rabbitmq.com/docs/publishers#message-properties), there's a message property called "type". I'm currently integrating against a 3rd party provider that requires this property for routing. It seems though,...

dnlsndr

Hello, I would like to limit the number of spawn thread when using tokio executor. I end up using ```rust let semaphore = Arc::new(Semaphore::new(32)); consumer.set_delegate(move |delivery: DeliveryResult| { let semaphore_clone...

doubleailes

Hi, this might be connected to #389 but my issue is that the process hangs instead of returning error on the operation (instead of not reconnecting on shutdown), let me...

alloncm

Hi, I successfully integrated lapin with the tokio runtime but I noticed it was still pulling 2 different versions of async-io. Is there a way to make that optional? ```...

nstinus

I'm using Redis as my broker in one of my project. So is there a way to use lapin with Redis as the broker?

suryan-s