rust-amqp

rust-amqp copied to clipboard

Silent failure to ack some messages

2

I need to handle several message in parallel so I couldn't use a consumer (see #38), I'm thus using the GetIterator approach. I have some code that looks like this:...

Keruspe

Channel.exchange_declare: Unexpected method frame

1

Steps to reproduce: Notice `auto_delete` changes. ``` rust channel.exchange_declare(exchange, "fanout", false, // pssive false, // durable false, // auto_delete false, // internal false, // nowait Table::new()) .unwrap(); channel.exchange_declare(exchange, "fanout", false,...

kopiczko

Consumer stops every <30 consumed messages

2

I'm running this code on cloudamqp with configuration: Cluster: cheerful-squirrel (change) RabbitMQ 3.5.7, Erlang 18.2 The program is able to consume up to 30 messages and I see that the...

kopiczko

Execution hangs when nowait is set to true

2

Execution of the code below hangs. When nowait parameter is set to false it returns immediately. I believe it also affects all API's with nowait parameter. ``` let mut ses...

kopiczko

Rework API for failure/success signaling

1

Currently there are several parts of rust-amqp where errors are being sunk, due to API not providing return values to signal errors/success. In order to be fixed, this requires changing...

lucab