78a4fb2f93
Bumps [rustix](https://github.com/bytecodealliance/rustix) from 0.37.19 to 0.37.25. - [Release notes](https://github.com/bytecodealliance/rustix/releases) - [Commits](https://github.com/bytecodealliance/rustix/compare/v0.37.19...v0.37.25) --- updated-dependencies: - dependency-name: rustix dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> |
||
|---|---|---|
| .. | ||
| src/bin | ||
| .gitignore | ||
| Cargo.lock | ||
| Cargo.toml | ||
| README.md | ||
Rust code for RabbitMQ tutorials (using Lapin)
Here you can find the Rust code examples for RabbitMQ tutorials.
The examples use lapin client library.
These tutorials assume a RabbitMQ server node running locally using default ports.
Requirements
Code
Each cargo command should be launched in a separate shell.
Tutorial one: "Hello World!"
cargo run --bin receive
cargo run --bin send
Tutorial two: Work Queues
cargo run --bin worker
cargo run --bin new_task "hi" # specify a custom message
Tutorial three: Publish/Subscribe
cargo run --bin receive_logs
cargo run --bin emit_log "hi" # specify a custom message
Tutorial four: Routing
cargo run --bin receive_logs_direct info error # specify log levels
cargo run --bin emit_log_direct error "help!" # specify severity and custom message
Tutorial five: Topics
cargo run --bin receive_logs_topic kern.* # specify topic filter
cargo run --bin emit_log_topic kern.mem "No memory left!" # specify topic and message
Tutorial six: RPC
cargo run --bin rpc_server
cargo run --bin rpc_client