amqprs

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

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 little external crates as possible.
3. lock free: no mutex/lock in client library itself.

Design Architecture

Example: Consume and Publish

Link to full example code

```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();

```