lapin
lapin copied to clipboard
amqp-rs
AMQP client library in Rust, with a clean, futures based API
I'm trying to use `confirm_select` and `wait_for_confirms` to get the list of acked/nacked messages, but every time I call `wait_for_confirms` it returns an empty `Vec`, even in the [example is...
I have a small script that is pushing messages to rabbit. It includes 2 processes: pulling data from a database and manipulating, and sending to rabbit. Internally this is done...
Hi, I believe I've found a memory leak which occurs when lapin fails to establish an amqp connection. It is possible to reproduce the issue with the code snippet below....
Hello, i wonder how client handles heartbeat timeout. From source it's clear to me that new valid heartbeat from server does nothing but just log. Is it possible to run...
Relatively new to rust so possible I'm just being dumb. What would be a good workaround for accessing something in the closure of a consumer delegate without violating the static...
When publishing to rabbit, if I use a ShortString as header, I get this error log: ``` ERROR lapin::channel: Connection closed on channel 0 by 0:0 => AMQPError { kind:...
thank you for you great library it is planned to support AMQP 1.0 sooner because I can't find anther crate to create AMQP 1.0 client? thank you in advance.
when use tokio consumer, the message is always one record behind ``` let properties = ConnectionProperties::default().with_tokio_executor(); let conn = Connection::connect(&config.uri, properties).await?; let channel = conn.create_channel().await?; let consumer = channel .basic_consume(...);...
I proceed with the long running task with the message queue. However, after about 2 hours, the consumer channel ends with an error message. What's the cause? ``` error: AMQP...
Now that we have the topology API, here are the steps required towards automatic reconnection: - [x] add an `Option` to the wrapped `basic_consume`, set it to None from the...
