camel_component_jms/
lib.rs

1//! JMS component for rust-camel — Apache ActiveMQ / Artemis bridge via Tower services.
2//!
3//! # Behavior changes (Phase B hardening)
4//!
5//! - **No automatic resend on transport errors** (breaking): Previously a send
6//!   transport error triggered a channel refresh + automatic retry. The retry
7//!   could duplicate non-idempotent writes. Now the channel is refreshed but
8//!   the original error is returned to the caller. Callers that want retry
9//!   semantics must implement it at the route level.
10//! - **max_bridges enforcement is now race-free**: Concurrent `get_or_create_slot`
11//!   calls are serialized during admission to prevent exceeding the configured
12//!   limit.
13//! - **Broker URLs are redacted in logs**: Userinfo (`user:pass@`) is replaced
14//!   with `***@` before logging.
15
16pub mod bundle;
17pub mod component;
18pub mod config;
19pub mod consumer;
20pub mod headers;
21pub mod health;
22pub mod producer;
23
24pub use bundle::JmsBundle;
25pub use camel_bridge::process::BrokerType;
26pub use component::{
27    BRIDGE_TRANSPORT_ERROR_PREFIX, BridgeSlot, BridgeState, JmsBridgePool, JmsComponent,
28    is_bridge_transport_error,
29};
30pub use config::default_bridge_cache_dir;
31pub use config::{
32    AcknowledgementMode, BrokerConfig, DestinationType, ExchangePattern, JmsEndpointConfig,
33    JmsPoolConfig, JmsTransactionMode,
34};
35pub use health::JmsHealthCheck;
36
37/// Version of the Java bridge binary this crate is compatible with.
38pub const BRIDGE_VERSION: &str = "0.3.0";
39
40pub mod proto {
41    tonic::include_proto!("jms_bridge");
42}
camel_component_jms/lib.rs

camel_component_jms/
lib.rs
