rocketmq-common-0.7.0
- rocketmq-common 0.7.0
- Docs.rs crate page
- MIT OR Apache-2.0
- Links
- Homepage
- Repository
- crates.io
- Source
- Owners
- mxsm
- Dependencies
- anyhow ^1.0.100 normal
  byteorder ^1.5.0 normal
  bytes ^1.11.0 normal
  cheetah-string ^0.1.7 normal
  chrono ^0.4.42 normal
  config ^0.15.19 normal
  crc ^3.4.0 normal
  dashmap ^6.1.0 normal
  dirs ^6.0 normal
  flate2 ^1.1.7 normal
  form_urlencoded ^1.2.2 normal
  futures ^0.3 normal
  hostname ^0.4 normal
  lazy_static ^1.5.0 normal
  local-ip-address ^0.6.4 normal
  lz4_flex ^0.12 normal
  num_cpus ^1.17 normal
  once_cell ^1.21.3 normal
  parking_lot ^0.12 normal
  regex ^1.12.2 normal
  reqwest ^0.12 normal
  rocketmq-error ^0.7.0 normal
  rocketmq-rust ^0.7.0 normal
  serde ^1.0 normal
  serde_json ^1.0 normal
  simd-json ^0.17.0 normal optional
  tempfile ^3.23.0 normal
  thiserror ^2.0.17 normal
  tokio ^1.48 normal
  tracing ^0.1.43 normal
  tracing-appender ^0.2.4 normal
  tracing-subscriber ^0.3.22 normal
  trait-variant ^0.1.2 normal
  url ^2.5.7 normal
  uuid ^1.19.0 normal
  zstd ^0.13 normal
  criterion ^0.8 dev
  mockall ^0.14.0 dev
- Versions
- 9.86% of the crate is documented
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

decode_messages

rocketmq_common0.7.0

In rocketmq_common::common::message::message_decoder

rocketmq_common::common::message::message_decoder

Function decode_messages

pub fn decode_messages(buffer: &mut Bytes) -> Vec<Message>