pub struct JmsPoolConfig {
pub brokers: HashMap<String, BrokerConfig>,
pub max_bridges: usize,
pub bridge_start_timeout_ms: u64,
pub broker_reconnect_interval_ms: u64,
pub health_check_interval_ms: u64,
pub bridge_cache_dir: PathBuf,
pub reconnect: NetworkRetryPolicy,
}Fields§
§brokers: HashMap<String, BrokerConfig>§max_bridges: usize§bridge_start_timeout_ms: u64§broker_reconnect_interval_ms: u64§health_check_interval_ms: u64§bridge_cache_dir: PathBuf§reconnect: NetworkRetryPolicyImplementations§
Source§impl JmsPoolConfig
impl JmsPoolConfig
Sourcepub fn single_broker(
broker_url: impl Into<String>,
broker_type: BrokerType,
) -> Self
pub fn single_broker( broker_url: impl Into<String>, broker_type: BrokerType, ) -> Self
Convenience constructor for single-broker scenarios (tests, simple examples). Creates a pool with one broker named “default”.
Sourcepub fn validate(&self) -> Result<(), CamelError>
pub fn validate(&self) -> Result<(), CamelError>
Validates the config: all brokers must have non-empty URLs with a known
scheme, max_bridges must be >= 1, and all timing fields must be strictly
positive to prevent busy-loops.
Trait Implementations§
Source§impl Clone for JmsPoolConfig
impl Clone for JmsPoolConfig
Source§fn clone(&self) -> JmsPoolConfig
fn clone(&self) -> JmsPoolConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for JmsPoolConfig
impl Debug for JmsPoolConfig
Source§impl Default for JmsPoolConfig
impl Default for JmsPoolConfig
Source§impl<'de> Deserialize<'de> for JmsPoolConfig
impl<'de> Deserialize<'de> for JmsPoolConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for JmsPoolConfig
impl RefUnwindSafe for JmsPoolConfig
impl Send for JmsPoolConfig
impl Sync for JmsPoolConfig
impl Unpin for JmsPoolConfig
impl UnsafeUnpin for JmsPoolConfig
impl UnwindSafe for JmsPoolConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
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