posixmq

A Rust library for working with posix message queues.

rust let mq = posixmq::PosixMq::open("/queue")?; let mut buf = vec![0; mq.attributes().max_msg_size]; loop { let (priority, len) = mq.receive(&mut buf)?; println!("priority: {:3}, message: {}", priority, str::from_utf8(&buf[..len])?); }

Supported operating systems

Not all operating systems have posix message queues: Linux and most BSDs have them, but macOS, OpenBSD and Windows doesn't. See the crate documentation for details.

mio integration

On Linux, FreeBSD and DragonFlyBSD posix message queues can be polled, and therefore used with mio. This feature is not enabled by default; enable it in Cargo.toml with:

toml [dependencies] posixmq = {version="0.1", features=["mio"]}

Also remember to open the message queues in nonblocking mode.

Differences from posix_mq

• send() and receive() borrows byte slices instead of consuming and producing vectors, which avoids unnecessary allocations.
• Optionally integrates with mio so the message queues can be polled.
• Is dual-licensed Apache-2.0 and MIT instead of only MIT.

Minimum Rust version

The minimum supported Rust version is 1.31.
While the crate might currently compile on older versions, a minor release can break this. Until rustup has builds for DragonFlyBSD and Illumos, this crate will never require a newer Rust version than what is available in the DragonFlyBSD or Joyent repositories.

License

Licensed under either of

• Apache License, Version 2.0, (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.