Add 'ops/posix_mq.rs/' from commit 'f7d1a38da6'
git-subtree-dir: ops/posix_mq.rs git-subtree-mainline:8f68497269git-subtree-split:f7d1a38da6
This commit is contained in:
commit
b59c7e693c
9 changed files with 521 additions and 0 deletions
22
ops/posix_mq.rs/src/tests.rs
Normal file
22
ops/posix_mq.rs/src/tests.rs
Normal file
|
|
@ -0,0 +1,22 @@
|
|||
use super::*;
|
||||
|
||||
#[test]
|
||||
fn test_open_delete() {
|
||||
// Simple test with default queue settings
|
||||
let name = Name::new("/test-queue").unwrap();
|
||||
let queue = Queue::open_or_create(name)
|
||||
.expect("Opening queue failed");
|
||||
|
||||
let message = Message {
|
||||
data: "test-message".as_bytes().to_vec(),
|
||||
priority: 0,
|
||||
};
|
||||
|
||||
queue.send(&message).expect("message sending failed");
|
||||
|
||||
let result = queue.receive().expect("message receiving failed");
|
||||
|
||||
assert_eq!(message, result);
|
||||
|
||||
queue.delete();
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue