Module ibmmq 

IBM MQ source and sink over MQI (client library loaded at run time). IBM MQ source and sink over MQI, using IBM’s client library loaded at run time.

The source gets messages under syncpoint and commits each checkpoint’s unit of work only after the checkpoint is durable (at-least-once). Poison messages follow the queue’s own BOTHRESH and BOQNAME, moved atomically within the same unit of work. The sink puts under syncpoint and commits each unit of work before a write returns. Blocking MQI calls run on one owned thread per connector generation, never on the async runtime.

Re-exports

pub use sink::IbmMqSink;

pub use source::IbmMqSource;

Modules

config

IBM MQ source and sink configuration.

metadata

Typed MQMD fields and message properties: selectable columns appended after the payload.

sink

IBM MQ queue sink: MQPUT under syncpoint and MQCMIT per unit of work.

source

IBM MQ queue source over MQI with syncpoint-controlled gets.

Functions

register_ibmmq_sink

Registers the IBM MQ sink connector.

register_ibmmq_source

Registers the IBM MQ source connector.