Crate rocketmq_rust

Re-exports

pub use count_down_latch::CountDownLatch;

pub use rocketmq_tokio_lock::RocketMQTokioMutex;

pub use rocketmq_tokio_lock::RocketMQTokioRwLock;

pub use tokio as rocketmq;

Modules

count_down_latch

rocketmq_tokio_lock

Structs

ArcMut

RocketMQBlockingQueue

A thread-safe bounded blocking queue. To replace Java LinkedBlockingQueue.

Shutdown

SyncUnsafeCellWrapper

WeakArcMut

Traits

Timer

convert from netty Timer A trait representing a timer that can schedule and manage timed tasks.

Functions

wait_for_signal

On unix platforms we want to intercept SIGINT and SIGTERM This method returns if either are signalled

Attribute Macros

main

Re-export rocketmq main. Marks async function to be executed by the selected runtime. This macro helps set up a Runtime without requiring the user to use Runtime or Builder directly.