test/sysv_mq_test.rb in sysvmq-0.0.1 vs test/sysv_mq_test.rb in sysvmq-0.1.0
- old
+ new
@@ -109,6 +109,12 @@
}
sleep 0.01
thread.kill
end
+
+ def test_nonblocking_send_and_receive
+ message = "Hello World"
+ @mq.send(message, 1, SysVMQ::IPC_NOWAIT)
+ assert_equal message, @mq.receive(0, SysVMQ::IPC_NOWAIT)
+ end
end