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

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.