pub struct HttpConsumer { /* private fields */ }Implementations§
Source§impl HttpConsumer
impl HttpConsumer
pub fn new(config: HttpServerConfig) -> Self
Trait Implementations§
Source§impl Consumer for HttpConsumer
impl Consumer for HttpConsumer
Source§fn start<'life0, 'async_trait>(
&'life0 mut self,
ctx: 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,
ctx: 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 concurrency_model(&self) -> ConcurrencyModel
fn concurrency_model(&self) -> ConcurrencyModel
Declares this consumer’s natural concurrency model. Read more
Auto Trait Implementations§
impl Freeze for HttpConsumer
impl RefUnwindSafe for HttpConsumer
impl Send for HttpConsumer
impl Sync for HttpConsumer
impl Unpin for HttpConsumer
impl UnsafeUnpin for HttpConsumer
impl UnwindSafe for HttpConsumer
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