omq 0.11.1

Pure Rust ØMQ/ZeroMQ. Facade over omq-compio (default) or omq-tokio. Wire-compatible with libzmq.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

# omq

Facade crate for [omq](https://github.com/paddor/omq.rs). Re-exports one backend:

| Feature | Backend | Crate |
|---------|---------|-------|
| `compio-backend` (default) | Single-threaded, io_uring | [omq-compio](https://crates.io/crates/omq-compio) |
| `tokio-backend` | Multi-threaded, tokio | [omq-tokio](https://crates.io/crates/omq-tokio) |

Mutually exclusive.

## Install

```sh
cargo add omq                     # compio backend (default)
cargo add omq --no-default-features --features tokio-backend
```

## Usage

```rust
use omq::Socket;
use omq::prelude::*;

let push = Socket::new(SocketType::Push, Options::default());
push.bind("tcp://127.0.0.1:5555".parse()?).await?;

let pull = Socket::new(SocketType::Pull, Options::default());
pull.connect("tcp://127.0.0.1:5555".parse()?).await?;

push.send(Message::single("hello")).await?;
let msg = pull.recv().await?;
```

See the [workspace README](https://github.com/paddor/omq.rs) for benchmarks, feature matrix,
and interop details.

## License

ISC