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 schedule::executor::ExecutorConfig;

pub use schedule::executor::ExecutorPool;

pub use schedule::executor::TaskExecutor;

pub use schedule::scheduler::SchedulerConfig;

pub use schedule::scheduler::TaskScheduler;

pub use schedule::task::Task;

pub use schedule::task::TaskContext;

pub use schedule::task::TaskResult;

pub use schedule::task::TaskStatus;

pub use schedule::trigger::CronTrigger;

pub use schedule::trigger::DelayTrigger;

pub use schedule::trigger::DelayedIntervalTrigger;

pub use schedule::trigger::IntervalTrigger;

pub use schedule::trigger::Trigger;

pub use tokio as rocketmq;

Modules

count_down_latch

rocketmq_tokio_lock

schedule

task

Macros

service_manager

Helper macro to create a service thread implementation

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.