What is "amqprs"

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

Accepted to list in RabbitMQ official website.

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 ```