What is "amqprs"

Yet another RabbitMQ client implementation in rust with different design goals.

The library is accepted to list in RabbitMQ official website.

It's probably the best performance among existing Rust clients. See Benchmarks.

Design Philosophy

1. API first: easy to use and understand. Keep the API similar as python client library so that it is easier for users to move from there.
2. Minimum external dependencies: as few external crates as possible.
3. lock free: no mutex/lock in client library itself.

Design Architecture

Quick Start: Consume and Publish

```rust // open a connection to RabbitMQ server let connection = Connection::open(&OpenConnectionArguments::new( "localhost", 5672, "user", "bitnami", )) .await .unwrap(); connection .register_callback(DefaultConnectionCallback) .await .unwrap();

// open a channel on the connection let channel = connection.openchannel(None).await.unwrap(); channel .registercallback(DefaultChannelCallback) .await .unwrap();

// declare a queue let (queuename, _, _) = channel .queuedeclare(QueueDeclareArguments::default()) .await .unwrap() .unwrap();

// bind the queue to exchange let rountingkey = "amqprs.example"; let exchangename = "amq.topic"; channel .queuebind(QueueBindArguments::new( &queuename, exchangename, rountingkey, )) .await .unwrap();

////////////////////////////////////////////////////////////////// // start consumer with given name let args = BasicConsumeArguments::new( &queuename, "examplebasicpubsub" );

channel .basicconsume(DefaultConsumer::new(args.noack), args) .await .unwrap();

////////////////////////////////////////////////////////////////// // publish message let content = String::from( r#" { "publisher": "example" "data": "Hello, amqprs!" } "#, ) .into_bytes();

// create arguments for basicpublish let args = BasicPublishArguments::new(exchangename, rounting_key);

channel .basic_publish(BasicProperties::default(), content, args) .await .unwrap();

// channel/connection will be closed when drop. // keep the channel and connection object from dropping // before pub/sub is done. time::sleep(time::Duration::from_secs(1)).await; // explicitly close channel.close().await.unwrap(); connection.close().await.unwrap(); ```

Typical Examples

Example - Publish and Subscribe

Example - SSL/TLS

Optional Features

• "traces": enable tracing in the library.
• "compliance_assert": enable compliance assertion according to AMQP spec. If enabled, library always check user inputs and panic if any non-compliance. If disabled, then it relies on server to reject.
• "tls": enable SSL/TLS.
• "urispec": enable support of RabbitMQ URI Specification

Run Test Locally

Testing depends on RabbitMQ docker container.

```bash

start rabbitmq server

./start_rabbitmq.sh

run tests

./regression_test.sh

enable traces in test.

Note that it only takes effect if "traces" feature is enabled

RUSTLOG=debug ./regressiontest.sh ```

Benchmarks

See benchmarks's README