3d8ee62087
Change-Id: Iab7e00cc26a4f9727d3ab98691ef379921a33052 Reviewed-on: https://cl.tvl.fyi/c/depot/+/5240 Tested-by: BuildkiteCI Reviewed-by: kanepyork <rikingcoding@gmail.com> Reviewed-by: Profpatsch <mail@profpatsch.de> Reviewed-by: grfn <grfn@gws.fyi> Reviewed-by: tazjin <tazjin@tvl.su>
21 lines
546 B
Rust
21 lines
546 B
Rust
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().expect("deleting queue failed");
|
|
}
|