Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / amqp-rs/lapin issues and pull requests

#419 - Make using tokio as the executor easier

Issue - State: open - Opened by huuff 16 days ago - 1 comment

#418 - ci: switch to rabbitmq service

Pull Request - State: closed - Opened by Keruspe 3 months ago

#416 - Channel recovery

Pull Request - State: open - Opened by Keruspe 3 months ago - 1 comment

#416 - Channel recovery

Pull Request - State: open - Opened by Keruspe 3 months ago - 1 comment

#416 - Channel recovery

Pull Request - State: open - Opened by Keruspe 3 months ago - 2 comments

#415 - Sharing `Channel` over async green threads

Issue - State: open - Opened by raui100 3 months ago - 2 comments

#414 - Windows build issue rustls

Issue - State: closed - Opened by maxmindlin 4 months ago - 3 comments

#413 - Ensure we properly reply to connection close

Issue - State: closed - Opened by Keruspe 4 months ago

#412 - Add with_type() message property function

Issue - State: closed - Opened by dnlsndr 5 months ago - 6 comments

#411 - disable tls support, including avoid bring in those deps

Issue - State: closed - Opened by mark-e-hoffman 5 months ago - 2 comments

#410 - A cleaner way to limit tokio spawn than a tokio::sync::Semaphore

Issue - State: closed - Opened by doubleailes 6 months ago - 4 comments

#409 - basic_publish hangs upon server shutdown or connection closed by server

Issue - State: closed - Opened by alloncm 6 months ago - 8 comments

#408 - Make async runtimes optional

Issue - State: closed - Opened by nstinus 6 months ago - 1 comment

#407 - Integration with redis

Issue - State: closed - Opened by suryan-s 6 months ago - 2 comments

#406 - Add `rustls--ring` and `rustls--aws_lc_rs` features

Pull Request - State: closed - Opened by Mathieu-Lala 6 months ago - 1 comment

#405 - heartbeat: kill the TCP connection when no heartbeat from server

Pull Request - State: closed - Opened by Keruspe 7 months ago - 2 comments

#404 - heartbeat: monitor incoming heartbeats

Pull Request - State: closed - Opened by Keruspe 7 months ago - 1 comment

#403 - fix(heartbeat): stop heartbeat if connection is not active

Pull Request - State: closed - Opened by slavik-pastushenko 7 months ago - 4 comments

#401 - heartbeat is sent even after io loop panicked

Issue - State: closed - Opened by slavik-pastushenko 7 months ago - 9 comments

#400 - Don't try to close a connection that is in an error state

Pull Request - State: closed - Opened by desiderius 8 months ago - 4 comments

#399 - Request for a more comprehensive documentation

Issue - State: open - Opened by korir248 8 months ago - 1 comment

#398 - fix documentation on the default TLS crate

Pull Request - State: closed - Opened by fcelda 8 months ago - 1 comment

#397 - added RPC example

Pull Request - State: open - Opened by randommm 9 months ago - 1 comment

#396 - Connecting to Amazon MQ RabbitMQ Instance

Issue - State: closed - Opened by Barbacamanitu 9 months ago - 4 comments

#395 - Does consumer.next is cancellation-safe method?

Issue - State: open - Opened by henry42 10 months ago - 2 comments

#393 - A Tokio 1.x context was found, but it is being shutdown.

Issue - State: closed - Opened by JasterV about 1 year ago - 5 comments

#392 - InvalidChannelState(Error)

Issue - State: closed - Opened by alekspickle about 1 year ago - 7 comments

#391 - add Clone where it makes sense

Issue - State: closed - Opened by alekspickle about 1 year ago - 4 comments

#390 - derive Clone for Connection

Pull Request - State: closed - Opened by alekspickle about 1 year ago

#389 - Reconnect on shutting down AMQP service

Issue - State: closed - Opened by mjanssen about 1 year ago - 4 comments

#388 - Possible Memory Leak

Issue - State: closed - Opened by jsouto18 about 1 year ago - 7 comments

#387 - certificate authentication fails with ASN1Error InvalidData

Issue - State: closed - Opened by david-mohr about 1 year ago - 1 comment

#386 - Possible to connect via a SOCKS5 proxy?

Issue - State: closed - Opened by HerbCSO over 1 year ago - 3 comments

#385 - Restore Topology Example Fails

Issue - State: closed - Opened by percybolmer over 1 year ago - 1 comment

#384 - tokio.rs example doesn't work correctly

Issue - State: closed - Opened by eliaseinarsson over 1 year ago - 2 comments

#383 - #372 with comments fixed

Pull Request - State: closed - Opened by Mathieu-Lala over 1 year ago - 4 comments

#382 - invalid channel: 0 error

Issue - State: closed - Opened by luca-iachini over 1 year ago - 9 comments

#381 - reconnect example fix

Pull Request - State: closed - Opened by Zero-Fanker over 1 year ago

#380 - fix that hearbeat send never stops if IO loop encounters error .

Pull Request - State: closed - Opened by Zero-Fanker over 1 year ago - 3 comments

#379 - TLS Authentication fails when using OpenSSL V3.0.2

Issue - State: closed - Opened by noelatmerqury over 1 year ago - 1 comment

#378 - Fixed memory leak when connection fails

Pull Request - State: closed - Opened by cheshirskycode over 1 year ago - 4 comments

#377 - WSAStartup Error on Windows

Issue - State: open - Opened by Victor-N-Suadicani over 1 year ago - 7 comments

#376 - `consumer.set_delegate` vs `consumer.next()` inside `tokio::spawn`

Issue - State: closed - Opened by galah92 over 1 year ago - 3 comments

#375 - AMQPUri parsing does not support special characters

Issue - State: closed - Opened by sebastianhopkins-lh over 1 year ago - 3 comments

#374 - Help on ideas for gracefully shutting down tasks spawned by set_delegate

Issue - State: closed - Opened by 2snEM6 almost 2 years ago - 2 comments

#373 - Proper reading procedure

Issue - State: closed - Opened by alekspickle about 2 years ago - 6 comments

#372 - move async-std default runtime into a feature

Pull Request - State: closed - Opened by conradludgate about 2 years ago - 2 comments

#371 - Channel should have `on_error` too

Issue - State: closed - Opened by cynecx over 2 years ago - 4 comments

#370 - can not connect if password contains #$

Issue - State: closed - Opened by constlhq over 2 years ago - 3 comments

#369 - How to correlate published messages with wait_for_confirms?

Issue - State: closed - Opened by Roger over 2 years ago - 3 comments

#368 - Memory leak when connection fails

Issue - State: closed - Opened by gjonikas over 2 years ago - 3 comments

#367 - Connecting to non-existing vhost can hang the program

Issue - State: closed - Opened by prk3 over 2 years ago - 2 comments

#366 - Missing messages during publishing

Issue - State: closed - Opened by gudjonragnar over 2 years ago - 1 comment

#365 - Fix race condition with concurrent connection attempts

Pull Request - State: closed - Opened by 95ulisse over 2 years ago - 5 comments

#364 - Heartbeat timeout handling

Issue - State: closed - Opened by ystasivs over 2 years ago - 2 comments

#363 - Failed to use vendored-openssl feature

Issue - State: closed - Opened by ystasivs over 2 years ago - 2 comments

#362 - Add an example using Tokio runtime

Pull Request - State: closed - Opened by ndelvalle over 2 years ago - 3 comments

#361 - Consumer delegate static lifetime

Issue - State: closed - Opened by r2dliu over 2 years ago - 3 comments

#360 - Generic INTERNALERROR where using ShortString in headers

Issue - State: closed - Opened by nappa85 over 2 years ago - 1 comment

#359 - Usage with RabbitMQ delayed messages plugin

Issue - State: closed - Opened by cbioley almost 3 years ago - 4 comments

#358 - Handling shutdown without panic

Issue - State: closed - Opened by nheitz almost 3 years ago - 1 comment

#356 - Error using exchange_declare(). Can't create exchange

Issue - State: closed - Opened by fabracht almost 3 years ago - 1 comment

#355 - Can not run examples

Issue - State: closed - Opened by vsilent almost 3 years ago - 2 comments

#354 - Unexpected delay of 40 ms

Issue - State: closed - Opened by RustPanda almost 3 years ago - 1 comment

#353 - Unexpected queue declare-ok received

Issue - State: closed - Opened by valkum about 3 years ago - 20 comments

#352 - How to use the customer.set_delegate function with tokio::spawn

Issue - State: closed - Opened by videni about 3 years ago - 2 comments

#351 - How to assert queue?

Issue - State: closed - Opened by astrolemonade about 3 years ago - 2 comments

#350 - Example for tokio use is wrong

Issue - State: closed - Opened by snaggen about 3 years ago - 4 comments

#349 - Revert Frames::push_frames() to 1.8 non-async version, avoids sequencing issue

Pull Request - State: closed - Opened by tadman about 3 years ago - 1 comment

#348 - Unexpected stalls during repeated, rapid publishing calls on v2.0.0-alpha.4

Issue - State: closed - Opened by tadman about 3 years ago - 1 comment

#347 - Basic.Deliver failure when using Kubernetes networking for v1.8.0

Issue - State: closed - Opened by tadman about 3 years ago - 3 comments

#345 - Can we specify a specific port for Lapin client connection?

Issue - State: closed - Opened by videni about 3 years ago - 2 comments

#344 - lapin::Queue::message_count() return the count not correct

Issue - State: closed - Opened by Uchiha007 about 3 years ago - 8 comments

#343 - BITS error when built aside of mysql_async

Issue - State: closed - Opened by nappa85 over 3 years ago - 12 comments

#342 - Make the `acker` module public

Pull Request - State: closed - Opened by Ereski over 3 years ago - 1 comment

#341 - Change basic_publish payload from Vec<u8> to &[u8]

Pull Request - State: closed - Opened by whatisaphone over 3 years ago - 2 comments

#340 - How to run multiple consumers?

Issue - State: closed - Opened by vidyli over 3 years ago

#339 - how to use this library with actix-web

Issue - State: closed - Opened by vidyli over 3 years ago - 1 comment

#338 - [tokio-consumer] one message lag

Issue - State: closed - Opened by 51yu over 3 years ago - 2 comments

#337 - Windows: Error NotConnected on custom TLS connection

Issue - State: closed - Opened by robertoortiz389 over 3 years ago - 6 comments

#336 - method not found in `(lapin::Channel, Delivery)

Issue - State: closed - Opened by universon123 over 3 years ago - 2 comments

#335 - Infinite Loop Fix

Pull Request - State: closed - Opened by dbcfd over 3 years ago - 5 comments

#334 - Optional options

Issue - State: closed - Opened by fpagliughi over 3 years ago - 6 comments

#333 - handle unresponsive server

Issue - State: closed - Opened by obayemi over 3 years ago - 3 comments

#332 - ack method can not found in delivery

Issue - State: closed - Opened by wenewzhang over 3 years ago - 3 comments

#331 - CI - lint: add cargo doc check

Pull Request - State: closed - Opened by MarcoIeni over 3 years ago - 2 comments

#329 - RPC: Resolve promises when preconditions fail

Pull Request - State: closed - Opened by nightkr over 3 years ago - 5 comments

#328 - Can you release an alpha version from the executors?

Issue - State: closed - Opened by augustocdias over 3 years ago - 3 comments

#327 - Hang on next ack after double-ack

Issue - State: closed - Opened by nightkr over 3 years ago - 10 comments

#326 - amq-protocol new update breaking 2.0.0-alpha.2

Issue - State: closed - Opened by Miaxos over 3 years ago - 2 comments

#325 - Fix typos in error messages and documentation

Pull Request - State: closed - Opened by Deebster over 3 years ago - 1 comment

#324 - Intermittent connection failures

Issue - State: closed - Opened by konomith over 3 years ago - 7 comments

#323 - tokio-amqp probably shouldn't enable lapin/default feature

Issue - State: closed - Opened by nightkr over 3 years ago - 1 comment