pub struct JmsBundle { /* private fields */ }Expand description
Bundles the JMS component (jms/activemq/artemis schemes) with its pool lifecycle.
Implementations§
Source§impl JmsBundle
impl JmsBundle
pub fn new(cfg: JmsPoolConfig) -> Result<Self, CamelError>
pub fn pool(&self) -> Arc<JmsBridgePool>
Trait Implementations§
Source§impl ComponentBundle for JmsBundle
impl ComponentBundle for JmsBundle
Source§fn config_key() -> &'static str
fn config_key() -> &'static str
Key under [components.] in Camel.toml.
Source§fn from_toml(value: Value) -> Result<Self, CamelError>
fn from_toml(value: Value) -> Result<Self, CamelError>
Deserialize the raw toml::Value block for this bundle.
Source§fn register_all(self, ctx: &mut dyn ComponentRegistrar)
fn register_all(self, ctx: &mut dyn ComponentRegistrar)
Register all schemes this bundle owns into the context.
Auto Trait Implementations§
impl !RefUnwindSafe for JmsBundle
impl !UnwindSafe for JmsBundle
impl Freeze for JmsBundle
impl Send for JmsBundle
impl Sync for JmsBundle
impl Unpin for JmsBundle
impl UnsafeUnpin for JmsBundle
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request