Please check the build logs for more information.
See Builds for ideas on how to fix a failed build, or Metadata for how to configure docs.rs builds.
If you believe this is docs.rs' fault, open an issue.
AMQ protocol implementation in pure rust.
Note: The project is still in very early stages of development, it implements all the protocol parsing, but not all the protocol methods are wrapped/easy to use. Expect the API to be changed in the future.
What it currently can do:
- Connect to server
- Open/close channels
- Declare queues/exchanges
- All the methods from the Basic class are implemented, including get, publish, ack, nack, reject, consume. So you can send/receive messages.
Have a look at the examples in examples/
folder.
Connecting to the server & openning channel:
extern crate amqp;
use Session;
use table;
let mut session = open_url.unwrap;
let mut channel = session.open_channel.unwrap;
Note: This library supports TLS connections, via OpenSSL. However, this is an optional feature that is enabled by default but can be disabled at build-time (via
cargo --no-default-features
on the command-line, or withdefault-features = false
in yourCargo.toml
).
Declaring queue:
//The arguments come in following order:
//queue: &str, passive: bool, durable: bool, exclusive: bool, auto_delete: bool, nowait: bool, arguments: Table
let queue_declare = channel.queue_declare;
Publishing message:
channel.basic_publish;
This will send message: "Hello from rust!" to the queue named "my_queue_name".
The messages have type of Vec<u8>
, so if you want to send string, first you must convert it to Vec<u8>
.
Development notes:
The methods encoding/decoding code is generated using codegen.rb & amqp-rabbitmq-0.9.1.json spec.
To generate a new spec, run:
To build the project and run the testsuite, use cargo:
Moreover, there are several source examples to show library usage, and an interactive one to quickly test the library. They can be run directly from cargo: