Struct ServiceManager

pub struct ServiceManager<T: ServiceTask + 'static> { /* private fields */ }

Service thread implementation with lifecycle management

Implementations

impl<T: ServiceTask + 'static> ServiceManager<T>

pub fn new(service: T) -> Self

Create new service thread implementation

pub fn new_arc(service: Arc<T>) -> Self

pub async fn start(&self) -> RocketMQResult<()>

Start the service thread

pub async fn shutdown(&self) -> RocketMQResult<()>

Shutdown the service

pub async fn shutdown_with_interrupt( &self, interrupt: bool, ) -> RocketMQResult<()>

Shutdown the service with optional interrupt

pub fn make_stop(&self)

Make the service stop (without waiting)

pub fn wakeup(&self)

Wake up the service thread

pub async fn wait_for_running(&self, interval: Duration)

Wait for running with interval

pub fn is_stopped(&self) -> bool

Check if service is stopped

pub fn is_daemon(&self) -> bool

Check if service is daemon

pub fn set_daemon(&self, daemon: bool)

Set daemon flag

pub async fn get_lifecycle_state(&self) -> ServiceLifecycle

Get current service state

pub fn is_started(&self) -> bool

Check if service is started

Trait Implementations

impl<T: ServiceTask> AsRef<T> for ServiceManager<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.