Skip to main content

Crate camel_component_jms

Crate camel_component_jms 

Source
Expand description

JMS component for rust-camel — Apache ActiveMQ / Artemis bridge via Tower services.

§Behavior changes (Phase B hardening)

  • No automatic resend on transport errors (breaking): Previously a send transport error triggered a channel refresh + automatic retry. The retry could duplicate non-idempotent writes. Now the channel is refreshed but the original error is returned to the caller. Callers that want retry semantics must implement it at the route level.
  • max_bridges enforcement is now race-free: Concurrent get_or_create_slot calls are serialized during admission to prevent exceeding the configured limit.
  • Broker URLs are redacted in logs: Userinfo (user:pass@) is replaced with ***@ before logging.

Re-exports§

pub use bundle::JmsBundle;
pub use component::BRIDGE_TRANSPORT_ERROR_PREFIX;
pub use component::BridgeSlot;
pub use component::BridgeState;
pub use component::JmsBridgePool;
pub use component::JmsComponent;
pub use component::is_bridge_transport_error;
pub use config::default_bridge_cache_dir;
pub use config::AcknowledgementMode;
pub use config::BrokerConfig;
pub use config::DestinationType;
pub use config::ExchangePattern;
pub use config::JmsEndpointConfig;
pub use config::JmsPoolConfig;
pub use config::JmsTransactionMode;
pub use health::JmsHealthCheck;

Modules§

bundle
component
config
consumer
headers
health
producer
proto

Enums§

BrokerType

Constants§

BRIDGE_VERSION
Version of the Java bridge binary this crate is compatible with.