rocketmq-model
Runtime-neutral RocketMQ domain types and value-level utilities. This crate has no Tokio dependency and does not create clients, listeners, or background services.
Public surface
| Module | Responsibility |
|---|---|
message and common::message |
Queue identity, message representations, properties, flags, and message conversion helpers. |
codec |
Property-string and byte/hex conversion utilities. |
topic, lite, and allocation |
Topic, lite-subscription, and allocation contracts. |
common, time, and version |
Shared constants, attributes, time utilities, and protocol-version identity. |
boundary_type and result |
Shared value types for boundary and result handling. |
ModelContractViolation describes invalid model contracts. Shared operational errors use rocketmq-error.
Imports use rocketmq_model; the package name is rocketmq-model. Prefer these types over defining duplicate queue/message identities in consumers. Serialization names and enum values are compatibility surfaces.
Features and integration
Default features are empty. simd enables the optional simd-json dependency and the model paths guarded by that feature. It does not add network or runtime ownership.
Wire requests and responses belong to rocketmq-protocol; runtime capabilities belong to rocketmq-runtime.
Validation
Run from the root workspace with its pinned toolchain:
See Cargo.toml for dependencies and feature definitions. Licensed under Apache-2.0.