Crate rocketmq_rust

Source

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.