pub struct TimerConsumer { /* private fields */ }Trait Implementations§
Source§impl Consumer for TimerConsumer
impl Consumer for TimerConsumer
Source§fn start<'life0, 'async_trait>(
&'life0 mut self,
context: ConsumerContext,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn start<'life0, 'async_trait>(
&'life0 mut self,
context: ConsumerContext,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Start consuming messages, sending them through the provided context.
Source§fn stop<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn stop<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Stop consuming messages.
Source§fn suspend<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn suspend<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Temporarily suspend consuming messages without fully stopping. Read more
Source§fn resume<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn resume<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Resume consuming after a previous suspension. Read more
Source§fn concurrency_model(&self) -> ConcurrencyModel
fn concurrency_model(&self) -> ConcurrencyModel
Declares this consumer’s natural concurrency model. Read more
Auto Trait Implementations§
impl !Freeze for TimerConsumer
impl RefUnwindSafe for TimerConsumer
impl Send for TimerConsumer
impl Sync for TimerConsumer
impl Unpin for TimerConsumer
impl UnsafeUnpin for TimerConsumer
impl UnwindSafe for TimerConsumer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more