Struct IbmMqConfig 

pub struct IbmMqConfig {

    pub url: String,
    pub queue: Option<String>,
    pub topic: Option<String>,
    pub queue_manager: String,
    pub channel: String,
    pub username: Option<String>,
    pub password: Option<String>,
    pub cipher_spec: Option<String>,
    pub tls: TlsConfig,
    pub max_message_size: usize,
    pub wait_timeout_ms: i32,
    pub internal_buffer_size: Option<usize>,
    pub disable_status_inq: bool,
}

Connection settings for the IBM MQ Queue Manager.

Fields

url: String

Required. Connection URL in host(port) format. Supports comma-separated list for failover (e.g., host1(1414),host2(1414)).

queue: Option<String>

Target Queue name for point-to-point messaging. Optional if topic is set; defaults to route name if omitted.

topic: Option<String>

Target Topic string for Publish/Subscribe. If set, enables Subscriber mode (Consumer) or publishes to a topic (Publisher). Optional if queue is set.

queue_manager: String

Required. Name of the Queue Manager to connect to (e.g., QM1).

channel: String

Required. Server Connection (SVRCONN) Channel name defined on the QM.

username: Option<String>

Username for authentication. Optional; required if the channel enforces authentication.

password: Option<String>

Password for authentication. Optional; required if the channel enforces authentication.

cipher_spec: Option<String>

TLS CipherSpec (e.g., ANY_TLS12). Optional; required for encrypted connections.

tls: TlsConfig

TLS configuration settings (e.g., keystore paths). Optional.

max_message_size: usize

Maximum message size in bytes (default: 4MB). Optional.

wait_timeout_ms: i32

(Consumer only) Polling timeout in milliseconds (default: 1000ms). Optional.

internal_buffer_size: Option<usize>

Internal buffer size for the channel. Defaults to 100.

disable_status_inq: bool

If false, attempt to open the queue with INQUIRE permissions to fetch queue depth for status checks. Defaults to false.

Implementations

impl IbmMqConfig

pub fn new( url: impl Into<String>, queue_manager: impl Into<String>, channel: impl Into<String>, ) -> Self

Creates a new IBM MQ configuration with the specified connection URL, queue manager, and channel.

pub fn with_queue(self, queue: impl Into<String>) -> Self

pub fn with_topic(self, topic: impl Into<String>) -> Self

pub fn with_credentials( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for IbmMqConfig

fn clone(&self) -> IbmMqConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IbmMqConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IbmMqConfig

fn default() -> IbmMqConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for IbmMqConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl SecretExtractor for IbmMqConfig

fn extract_secrets( &mut self, prefix: &str, secrets: &mut HashMap<String, String>, )

Extracts secrets into the provided map using the given prefix, and clears them from self.

impl Serialize for IbmMqConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.