lapin

Signed-off-by: Marc-Antoine Perennou [email protected]

Features

• Documentation iprovements

Misc

• switch to event-listener for internal synchronisation

Signed-off-by: Marc-Antoine Perennou [email protected]

Bug Fixes

• Fix some doc-comments

Signed-off-by: Marc-Antoine Perennou [email protected]

Features

• Documentation overhaul

Signed-off-by: Marc-Antoine Perennou [email protected]

Bug Fixes

• Prevent possible (unlikely) race condition in notifier
• Use saturating arithmetics as much as possible

Misc

• Add some must_use annotations

Signed-off-by: Marc-Antoine Perennou [email protected]

Misc

• Misc project metadata cleanup

Signed-off-by: Marc-Antoine Perennou [email protected]

Bug Fixes

• Various build fixes with some feature combinations

Signed-off-by: Marc-Antoine Perennou [email protected]

Bug Fixes

• Properly clear dropped PublisherConfirms on channel error

Signed-off-by: Marc-Antoine Perennou [email protected]

Misc

• Added ErrorKind::FutureCompleted
• Some internal cleanups

Features

• Add durable/exclusive constructors on QueueDeclareOptions for better defaults.
• Add auto_delete/passive helpers on QueueDeclareOptions to facilitate using these features.

Features

• New rustls-platform-verifier feature (new default)

Misc

• Reworked internal state handling during early connection steps

Bug Fixes

• Updated async-rs to 0.8.2 to make sure the lapin Internal RPC loop is bound to the right tokio context

Misc

• Added ErrorKind::RuntimeShutdownError and reworked internal detection and handling

Features

• We now use exponential backoff for retries of AMQP connection too once the TCP connection is established

Misc

• Added an example of semi automatic reconnection handling

Bug Fixes

• Fixes an issue preventing us from preoperly reconnecting during a rabbitmq server restart

Bug Fixes

• Properly handle errors emitted by tokio when reactor is shutting down

Breaking changes

• The closure passed to ConnectionProperties::configure_backoff now needs to return the ExponentialBuilder

Bug Fixes

• ConnectionProperties::configure_backoff now works properly. It was previously broken due to implicit Copy behaviour.
• We now retry several times (16 as of now) the TCP connection itself by default when recovery is enabled.

Bug Fixes

• PublisherConfirms is now public

Features

• ConnectionBuilder (and ConnectionProperties) now implement Debug

Features

• New ConnectionBuilder (and DefaultConnectionBuilder) types to centralize everything related to connecting.

Bug Fixes

• ConnectionProperties reimplements Clone

Breaking changes

• Make more use of protocol types in public api (mostly ShortString and LongString)
• Automatic connection recovery is now done through ConnectionProperties::enable_auto_recover()
• Automatic connection recovery is no longer feature-gated by the unstable feature (which has been removed)
• Automatic channel recovery is gone. Channels will still be recovered during connection recovery, but not outside of this scenario.

Features

• New feature flags to control default runtime (tokio, smol)
• Removed deprecated on_error callback setup. Use Connection::events_listener instead.
• Runtime is now configured in the Connection::connect_with_runtime method
• Connection::block and Connection:unblock have been removed (they were actually a protocol violation)
• Replaced Acker::mock with Delivery::mock
• Changed Connection::collector callback to an async fn
• Added an AuthProvider mechanism configurable through ConnectionProperties (to support e.g. automatic oauth2 token refresh)

Misc

• Switched our async runtimes integration from executor-trait and reactor-trait to async-rs
• Update amq-protocol to 10.0

Bug Fixes

• Fix defunct io_loop threads being kept in a deadlock on (very) early connection failure

Bug Fixes

• Fix io_loop tracing span

Bug Fixes

• Make sure we don't run the heartbeat loop multiple times after reconnection

Features

• Allow configuring the backoff for TCP connection more easily

Features

• Allow configuring exponential backoff for retrying TCP connection (using the backon crate)

Bug Fixes

• Fix rabbit-cr-demo auth
• Make sure we always recover on connection process errors

Features

• Add Connection::events_listener for listening to internal events

Misc

• Add Acker::mock() to help writing tests in external programs

Features

• Add hickory-dns feature to use hickory-dns for domain name resolution to avoid spurious network hangs

Bug Fixes

• Fix hang when rabbitmq server is unavailable when connecting.
• Fix crash in tokio reactor initial usage

Features

• Add experimental ability to recover on connection failure

Misc

• Drop waker-fn dependency

Bug Fixes

• When the server closes the TCP connection, handle the ongoing frames before erroring out

Misc

• Several fixes related to channel automatic reconnection
• Internal preparatory work for upcoming connection recovery

Features

• Channel::wait_for_recovery to wait for automatic reconnection to finish (if we're in the process of reconnecting)

Misc

• Several fixes related to channel automatic reconnection
• Internal preparatory work for upcoming connection recovery

Breaking changes

• Error is now ErrorKind, wrapped in a new Error type (use Error::kind to access the previous type)
• no more Acker::default
• Acker::used is replaced with Acker::usable
• Removed the topology API

Features

• rustls crypto backend selection through features
• Error::is_amqp_error, Error::is_amqp_soft_error and Error::is_amqp_hard_error
• default runtime is now optional
• experimental feature to recover channel from AMQP soft error (behind unstable feature flag)

• Acker::poisoned to check if underlying Channel has been invalidated (reconnection)

Misc

• Update to reactor-trait 2
• Update to amq-protocol 8
• Update to nom 8
• Drop parking-lot dependency
• Drop pinky-swear dependency
• Edition 2024

Bug Fixes

• Fix io_loop tracing span

Features

• Propagate current tracing span into io_loop thread

Bug Fixes

• Fix a panic when reaching the maximum number of channels

Bug Fixes

• Fix potential deadlock in server protocol error handling

Bug Fixes

• Fix potential overflow (only in a log message)

Bug Fixes

• Better handle in flight frames on io loop termination.

Bug Fixes

• Prevent basic_publish hangs in some rare corner case

Features

• Allow closing Acker and checking if already used

Bug Fixes

• Close connection to server in case of missing heartbeat

Misc

• Dependencies update

Bug Fixes

• Don't allow trying to close an already closed connection
• Make sure heartbeats are no longer sent after a connection error

Misc

• Simplify channels cleanup logic on connection close

Bug Fixes

• Fix an error when finalizing the connection close duz to missing channel 0.
• Properly cleanup heartbeat sending when connection hit an error.

Bug Fixes

• Don't call the channel error hook when we get closed with a non error code

Features

• Introduce Channel::on_error

Bug Fixes

• Don't propagate the same error twice

Bug Fixes

• Fix memory leak on connection failure

Bug Fixes

• Fix potential race condition on connection error

Bug Fixes

• Fix potential race condition on connection opening

Misc

• Update amq-protocol