ibm_mq

Connects to IBM MQ queue managers and consumes messages from specified queues.

Common
Advanced

# Common config fields, showing default values
input:
  label: ""
  ibm_mq:
    queue_manager_name: QM1 # No default (required)
    queue_name: DEV.QUEUE.1 # No default (required)
    channel_name: DEV.APP.SVRCONN # No default (required)
    connection_name: localhost(1414) # No default (required)
    user_id: ""
    password: ""

# Advanced config fields, showing default values
input:
  label: ""
  ibm_mq:
    queue_manager_name: QM1 # No default (required)
    queue_name: DEV.QUEUE.1 # No default (required)
    channel_name: DEV.APP.SVRCONN # No default (required)
    connection_name: localhost(1414) # No default (required)
    user_id: ""
    password: ""
    application_name: wombat
    batch_size: 1
    batch_wait_time: 100ms
    tls:
      enabled: false
      cipher_spec: ""
      key_repository: ""
      key_repository_password: ""
      certificate_label: ""
      ssl_peer_name: ""
      fips_required: false

Connects to IBM MQ queue managers and consumes messages from specified queues.

Uses IBM MQ input component found in wombatwisdom/components.

Build Requirements

This component requires IBM MQ client libraries. Build with the mqclient build tag:

go build -tags mqclient

Fields

`queue_manager_name`

The queue manager to connect to

Type: string

# Examples

queue_manager_name: QM1

`queue_name`

The queue name to read messages from

Type: string

# Examples

queue_name: DEV.QUEUE.1

`channel_name`

The channel name for client connections

Type: string

# Examples

channel_name: DEV.APP.SVRCONN

`connection_name`

The connection name in the format hostname(port)

Type: string

# Examples

connection_name: localhost(1414)

`user_id`

Optional: The user ID for authentication

Type: string

Default: ""

`password`

Optional: The user password for authentication

Type: string

Default: ""

`application_name`

Optional: Application name for MQ connection identification

Type: string

Default: "wombat"

`batch_size`

Maximum number of messages to batch together

Type: int

Default: 1

`batch_wait_time`

Maximum time to wait for a complete batch before returning partial batch

Type: string

Default: "100ms"

`tls`

TLS/SSL configuration for secure connections

Type: object

`tls.enabled`

Enable TLS encryption for the connection

Type: bool

Default: false

`tls.cipher_spec`

The cipher specification to use for TLS

Type: string

Default: ""

# Examples

cipher_spec: TLS_RSA_WITH_AES_128_CBC_SHA256

`tls.key_repository`

Path to the key repository containing certificates (without file extension)

Type: string

Default: ""

# Examples

key_repository: /opt/mqm/ssl/key

`tls.key_repository_password`

Password for the key repository

Type: string

Default: ""

`tls.certificate_label`

Certificate label to use from the key repository

Type: string

Default: ""

`tls.ssl_peer_name`

Peer name for SSL/TLS validation

Type: string

Default: ""

`tls.fips_required`

Require FIPS 140-2 compliant algorithms

Type: bool

Default: false