Module ibm.ibmmq

ballerinax/ibm.ibmmq Ballerina library

0.1.3

Overview

The ballerinax/ibm.ibmmq module provides an API to connect to an IBM MQ server using Ballerina.

This module is created with minimal deviation from the IBM MQ java client API to make it easy for the developers who are used to working with the IBM MQ java client.

Currently, the following IBM MQ API Classes are supported through this package.

QueueManager
Queue
Destination (Queue, Topic)
Message

IBM MQ queue

IBM MQ queues are used for point-to-point messaging. In point-to-point messaging, a producer application sends a message to a queue, and a single consumer application retrieves the message from the queue.

Producer


import ballerinax/ibm.ibmmq;

public function main() returns error? {
    ibmmq:QueueManager queueManager = check new (
        name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"
    );
    ibmmq:Queue producer = check queueManager.accessQueue("DEV.QUEUE.1", ibmmq:MQOO_OUTPUT);
    check producer->put({
        payload: "This is a sample message to IBM MQ queue".toBytes()
    });
    check producer->close();
    check queueManager.disconnect();
}

Consumer


import ballerinax/ibm.ibmmq;
import ballerina/io;

public function main() returns error? {
    ibmmq:QueueManager queueManager = check new (
        name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"
    );
    ibmmq:Queue consumer = check queueManager.accessQueue(
            "DEV.QUEUE.1", ibmmq:MQOO_INPUT_AS_Q_DEF);
    while true {
        ibmmq:Message? message = check consumer->get(options = ibmmq:MQGMO_WAIT);
        if message is () {
            continue;
        }
        io:println(string:fromBytes(message.payload));
    }
}

IBM MQ topic

IBM MQ topics are used in the publish/subscribe (pub/sub) messaging model. In pub/sub, publishers send messages to topics, and subscribers subscribe to topics. When a publisher sends a message to a topic, the queue manager delivers the message to all subscribers that are subscribed to that topic.

Publisher


import ballerinax/ibm.ibmmq;

public function main() returns error? {
    ibmmq:QueueManager queueManager = check new (
        name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"
    );
    ibmmq:Topic publisher = check queueManager.accessTopic(
        "dev", "DEV.BASE.TOPIC", ibmmq:OPEN_AS_PUBLICATION, ibmmq:MQOO_OUTPUT);
    check publisher->put({
        payload: "This is a sample message to IBM MQ topic".toBytes()
    });
    check publisher->close();
    check queueManager.disconnect();
}

Subscriber


import ballerinax/ibm.ibmmq;
import ballerina/io;

public function main() returns error? {
    ibmmq:QueueManager queueManager = check new(
        name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN");
    ibmmq:Topic subscriber = check queueManager.accessTopic(
        "dev", "DEV.BASE.TOPIC", ibmmq:OPEN_AS_SUBSCRIPTION, ibmmq:MQSO_CREATE);
    while true {
        ibmmq:Message? message = check subscriber->get(options = ibmmq:MQGMO_WAIT);
        if message is () {
            continue;
        }
        io:println(string:fromBytes(message.payload));
    }
}

Classes

ibm.ibmmq: QueueManager

Isolated

Represents an IBM MQ queue manager.

Constructor

Initialize an IBM MQ queue manager.

ibmmq:QueueManager queueManager = check new(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN");

init (*QueueManagerConfiguration configurations)

configurations *QueueManagerConfiguration - The configurations to be used when initializing the IBM MQ queue manager

accessQueue

Isolated Function

function accessQueue(string queueName, int options) returns Queue|Error

Establishes access to an IBM MQ queue on this queue manager.


ibmmq:Queue queue = check queueManager.accessQueue("queue1", ibmmq:MQOO_OUTPUT);

Parameters

queueName string - Name of the queue

options int - The options which control the opening of the queue

Return Type

Queue|Error - The ibmmq:Queue object or an ibmmq:Error if the operation failed

accessTopic

Isolated Function

function accessTopic(string topicName, string topicString, OPEN_TOPIC_OPTION openTopicOption, int options) returns Topic|Error

Establishes access to an IBM MQ topic on this queue manager.


ibmmq:Topic topic = check queueManager.accessTopic(
  "dev", "DEV.BASE.TOPIC", ibmmq:OPEN_AS_PUBLICATION, ibmmq:MQOO_OUTPUT
);

Parameters

topicName string - The topic string to publish or subscribe against

topicString string - The name of the topic object as defined on the local queue manager

openTopicOption OPEN_TOPIC_OPTION - Indicates whether the topic is being opened for either publication or subscription

options int - Options that control the opening of the topic for either publication or subscription

Return Type

Topic|Error - The ibmmq:Topic object or an ibmmq:Error if the operation failed

disconnect

Isolated Function

function disconnect() returns Error?

Clients

ibm.ibmmq: Queue

Isolated

IBM MQ Queue client.

put

Isolated FunctionRemote Function

function put(Message message) returns Error?

Puts a message to an IBM MQ queue.

Parameters

message Message - IBM MQ message

Return Type

Error? - An ibmmq:Error if the operation fails or else ()

get

Isolated FunctionRemote Function

function get(*GetMessageOptions getMessageOptions) returns Message|Error?

Retrieves a message from an IBM MQ queue.

Parameters

getMessageOptions *GetMessageOptions - Options to control message retrieval

Return Type

Message|Error? - An ibmmq:Message if there is a message in the queue, () if there is no message or else ibmmq:Error if the operation fails

close

Isolated FunctionRemote Function

function close() returns Error?

Closes the IBM MQ queue object. No further operations on this object are permitted after it is closed.

Return Type

Error? - An ibmmq:Error if the operation fails or else ()

ibm.ibmmq: Topic

Isolated

IBM MQ Topic client.

put

Isolated FunctionRemote Function

function put(Message message) returns Error?

Puts a message to an IBM MQ topic.

Parameters

message Message - IBM MQ message

Return Type

Error? - An ibmmq:Error if the operation fails or else ()

get

Isolated FunctionRemote Function

function get(*GetMessageOptions getMessageOptions) returns Message|Error?

Retrieves a message from an IBM MQ topic.

Parameters

getMessageOptions *GetMessageOptions - Options to control message retrieval

Return Type

Message|Error? - An ibmmq:Message if there is a message in the topic, () if there is no message or else ibmmq:Error if the operation fails

close

Isolated FunctionRemote Function

function close() returns Error?

Closes the IBM MQ topic object. No further operations on this object are permitted after it is closed.

Return Type

Error? - An ibmmq:Error if the operation fails or else ()

Constants

ibm.ibmmq: ANY

string "*ANY"

Any supported SSL/TLS cipher suite.

ibm.ibmmq: MQGMO_ACCEPT_TRUNCATED_MSG

int 64

If the message buffer is too small to hold the complete message, allow the MQGET call to fill the buffer with as much of the message as the buffer can hold.

ibm.ibmmq: MQGMO_BROWSE_FIRST

int 16

When a queue is opened with the MQOO_BROWSE option, a browse cursor is established, positioned logically before the first message on the queue.

ibm.ibmmq: MQGMO_BROWSE_MSG_UNDER_CURSOR

int 2048

Retrieve the message pointed to by the browse cursor nondestructively, regardless of the MQMO_* options specified in the MatchOptions field in MQGMO.

ibm.ibmmq: MQGMO_BROWSE_NEXT

int 32

Advance the browse cursor to the next message on the queue that satisfies the selection criteria specified on the MQGET call.

ibm.ibmmq: MQGMO_CONVERT

int 16384

Requests the application data to be converted.

ibm.ibmmq: MQGMO_FAIL_IF_QUIESCING

int 8192

Force the MQGET call to fail if the queue manager is in the quiescing state.

ibm.ibmmq: MQGMO_LOCK

int 512

Lock the message that is browsed, so that the message becomes invisible to any other handle open for the queue.

ibm.ibmmq: MQGMO_MSG_UNDER_CURSOR

int 256

Retrieve the message pointed to by the browse cursor, regardless of the MQMO_* options specified in the MatchOptions field in MQGMO.

ibm.ibmmq: MQGMO_NO_SYNCPOINT

int 4

The request is to operate outside the normal unit-of-work protocols.

ibm.ibmmq: MQGMO_NO_WAIT

int 0

The application does not wait if no suitable message is available.

ibm.ibmmq: MQGMO_SYNCPOINT

int 2

The request is to operate within the normal unit-of-work protocols.

ibm.ibmmq: MQGMO_UNLOCK

int 1024

Unlock a message. The message to be unlocked must have been previously locked by an MQGET call with the MQGMO_LOCK option.

ibm.ibmmq: MQGMO_WAIT

int 1

The application waits until a suitable message arrives.

ibm.ibmmq: MQOO_ALTERNATE_USER_AUTHORITY

int 4096

Enables the AlternateUserId field in the ObjDesc parameter contains a user identifier to use to validate this MQOPEN call.

ibm.ibmmq: MQOO_BIND_AS_Q_DEF

int 0

The local queue manager binds the queue handle in the way defined by the DefBind queue attribute.

ibm.ibmmq: MQOO_BROWSE

int 8

Open the queue to browse messages.

ibm.ibmmq: MQOO_FAIL_IF_QUIESCING

int 8192

The MQOPEN call fails if the queue manager is in quiescing state. This option is valid for all types of object.

ibm.ibmmq: MQOO_INPUT_AS_Q_DEF

int 1

Open the queue to get messages using the queue-defined default.

ibm.ibmmq: MQOO_INPUT_EXCLUSIVE

int 4

Open the queue to get messages with exclusive access.

ibm.ibmmq: MQOO_INPUT_SHARED

int 2

Open the queue to get messages with shared access.

ibm.ibmmq: MQOO_OUTPUT

int 16

Open the queue to put messages.

ibm.ibmmq: MQOO_PASS_ALL_CONTEXT

int 512

This allows the MQPMO_PASS_ALL_CONTEXT option to be specified in the PutMsgOpts parameter when a message is put on a queue.

ibm.ibmmq: MQOO_PASS_IDENTITY_CONTEXT

int 256

This allows the MQPMO_PASS_IDENTITY_CONTEXT option to be specified in the PutMsgOpts parameter when a message is put on a queue.

ibm.ibmmq: MQOO_SET_ALL_CONTEXT

int 2048

This allows the MQPMO_SET_ALL_CONTEXT option to be specified in the PutMsgOpts parameter when a message is put on a queue.

ibm.ibmmq: MQOO_SET_IDENTITY_CONTEXT

int 1024

This allows the MQPMO_SET_IDENTITY_CONTEXT option to be specified in the PutMsgOpts parameter when a message is put on a queue.

ibm.ibmmq: MQSO_CREATE

int 2

Subscribe Option create

ibm.ibmmq: OPEN_AS_PUBLICATION

int 2

Open topic as a publication.

ibm.ibmmq: OPEN_AS_SUBSCRIPTION

int 1

Open topic as a subscription.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA

string "SSL_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA"

SSL cipher suite using ECDHE-ECDSA for key exchange with 3DES encryption and SHA integrity.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256

string "SSL_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256"

SSL cipher suite using ECDHE-ECDSA for key exchange with AES 128-bit encryption and SHA-256 integrity.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256

string "SSL_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256"

SSL cipher suite using ECDHE-ECDSA for key exchange with AES 128-bit GCM encryption and SHA-256 integrity.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384

string "SSL_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384"

SSL cipher suite using ECDHE-ECDSA for key exchange with AES 256-bit CBC encryption and SHA-384 integrity.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384

string "SSL_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384"

SSL cipher suite using ECDHE-ECDSA for key exchange with AES 256-bit GCM encryption and SHA-384 integrity.

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_NULL_SHA

string "SSL_ECDHE_ECDSA_WITH_NULL_SHA"

SSL cipher suite using ECDHE-ECDSA for key exchange with NULL encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_RC4_128_SHA

string "SSL_ECDHE_ECDSA_WITH_RC4_128_SHA"

SSL cipher suite using ECDHE-ECDSA for key exchange with RC4 128-bit encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: SSL_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA

string "SSL_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA"

SSL cipher suite using ECDHE-RSA for key exchange with 3DES encryption and SHA integrity.

ibm.ibmmq: SSL_ECDHE_RSA_WITH_AES_128_CBC_SHA256

string "SSL_ECDHE_RSA_WITH_AES_128_CBC_SHA256"

SSL cipher suite using ECDHE-RSA for key exchange with AES 128-bit encryption and SHA-256 integrity.

ibm.ibmmq: SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256

string "SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256"

SSL cipher suite using ECDHE-RSA for key exchange with AES 128-bit GCM encryption and SHA-256 integrity.

ibm.ibmmq: SSL_ECDHE_RSA_WITH_AES_256_CBC_SHA384

string "SSL_ECDHE_RSA_WITH_AES_256_CBC_SHA384"

SSL cipher suite using ECDHE-RSA for key exchange with AES 256-bit CBC encryption and SHA-384 integrity.

ibm.ibmmq: SSL_ECDHE_RSA_WITH_AES_256_GCM_SHA384

string "SSL_ECDHE_RSA_WITH_AES_256_GCM_SHA384"

SSL cipher suite using ECDHE-RSA for key exchange with AES 256-bit GCM encryption and SHA-384 integrity.

ibm.ibmmq: SSL_ECDHE_RSA_WITH_NULL_SHA

string "SSL_ECDHE_RSA_WITH_NULL_SHA"

SSL cipher suite using ECDHE-RSA for key exchange with NULL encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: SSL_ECDHE_RSA_WITH_RC4_128_SHA

string "SSL_ECDHE_RSA_WITH_RC4_128_SHA"

SSL cipher suite using ECDHE-RSA for key exchange with RC4 128-bit encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: SSL_RSA_WITH_3DES_EDE_CBC_SHA

string "SSL_RSA_WITH_3DES_EDE_CBC_SHA"

SSL cipher suite using RSA for key exchange with 3DES encryption and SHA integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_128_CBC_SHA

string "SSL_RSA_WITH_AES_128_CBC_SHA"

SSL cipher suite using RSA for key exchange with AES 128-bit encryption and SHA integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_128_CBC_SHA256

string "SSL_RSA_WITH_AES_128_CBC_SHA256"

SSL cipher suite using RSA for key exchange with AES 128-bit encryption, SHA-256 integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_128_GCM_SHA256

string "SSL_RSA_WITH_AES_128_GCM_SHA256"

SSL cipher suite using RSA for key exchange with AES 128-bit GCM encryption, SHA-256 integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_256_CBC_SHA

string "SSL_RSA_WITH_AES_256_CBC_SHA"

SSL cipher suite using RSA for key exchange with AES 256-bit CBC encryption and SHA integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_256_CBC_SHA256

string "SSL_RSA_WITH_AES_256_CBC_SHA256"

SSL cipher suite using RSA for key exchange with AES 256-bit CBC encryption, SHA-256 integrity.

ibm.ibmmq: SSL_RSA_WITH_AES_256_GCM_SHA384

string "SSL_RSA_WITH_AES_256_GCM_SHA384"

SSL cipher suite using RSA for key exchange with AES 256-bit GCM encryption, SHA-384 integrity.

ibm.ibmmq: SSL_RSA_WITH_DES_CBC_SHA

string "SSL_RSA_WITH_DES_CBC_SHA"

SSL cipher suite using RSA for key exchange with DES encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: SSL_RSA_WITH_NULL_SHA256

string "SSL_RSA_WITH_NULL_SHA256"

SSL cipher suite using RSA for key exchange with NULL encryption and SHA-256 integrity (not recommended for production use).

ibm.ibmmq: SSL_RSA_WITH_RC4_128_SHA

string "SSL_RSA_WITH_RC4_128_SHA"

SSL cipher suite using RSA for key exchange with RC4 128-bit encryption and SHA integrity (not recommended for production use).

ibm.ibmmq: TLS12

string "*TLS12"

TLS 1.2 protocol version.

ibm.ibmmq: TLS12ORHIGHER

string "*TLS12ORHIGHER"

TLS 1.2 or higher protocol version.

ibm.ibmmq: TLS13

string "*TLS13"

TLS 1.3 protocol version.

ibm.ibmmq: TLS13ORHIGHER

string "*TLS13ORHIGHER"

TLS 1.3 or higher protocol version.

ibm.ibmmq: TLS_AES_128_CCM_8_SHA256

string "TLS_AES_128_CCM_8_SHA256"

SSL cipher suite using AES 128-bit CCM 8 encryption, SHA-256 integrity.

ibm.ibmmq: TLS_AES_128_CCM_SHA256

string "TLS_AES_128_CCM_SHA256"

SSL cipher suite using AES 128-bit CCM encryption, SHA-256 integrity.

ibm.ibmmq: TLS_AES_128_GCM_SHA256

string "TLS_AES_128_GCM_SHA256"

SSL cipher suite using AES 128-bit GCM encryption, SHA-256 integrity.

ibm.ibmmq: TLS_AES_256_GCM_SHA384

string "TLS_AES_256_GCM_SHA384"

SSL cipher suite using AES 256-bit GCM encryption, SHA-384 integrity.

ibm.ibmmq: TLS_CHACHA20_POLY1305_SHA256

string "TLS_CHACHA20_POLY1305_SHA256"

SSL cipher suite using ChaCha20-Poly1305 encryption, SHA-256 integrity.

Records

ibm.ibmmq: CertKey

Closed record

Represents a combination of certificate, private key, and private key password if encrypted.

Fields

certFile string - A file containing the certificate

keyFile string - A file containing the private key in PKCS8 format

keyPassword string? - Password of the private key if it is encrypted

ibm.ibmmq: ErrorDetails

Closed record

The error details type for the IBM MQ module.

Fields

reasonCode int? - The reason code for the error

errorCode string? - The error code for the error

completionCode int? - The completion code for the error

ibm.ibmmq: GetMessageOptions

Closed record

IBM MQ get message options.

Fields

options int(default MQGMO_NO_WAIT) - Get message option

waitInterval int(default 10) - The maximum time (in seconds) that a get call waits for a suitable message to arrive. It is used in conjunction with ibmmq.MQGMO_WAIT.

ibm.ibmmq: Message

Closed record

Represents an IBM MQ message.

Fields

properties map<Property>? - Message properties

format string? - Format associated with the header

messageId byte[]? - Message identifier

correlationId byte[]? - Correlation identifier

expiry int? - Message lifetime

priority int? - Message priority

persistence int? - Message persistence

messageType int? - Message type

putApplicationType int? - Type of application that put the message

replyToQueueName string? - Name of reply queue

replyToQueueManagerName string? - Name of reply queue manager

headers Header[]? - Headers to be sent in the message

payload byte[] - Message payload

ibm.ibmmq: MQCIH

Closed record

Header record representing the MQCIH structure.

Fields

flags int(default 0) - Flag of the header

encoding int(default 0) - field description

codedCharSetId int(default 0) - field description

format string(default DEFAULT_BLANK_VALUE) - MQ format name of data that follows MQCIH

strucId string(default "CIH ") - Structure identifier

strucLength int(default 180) - Length of the structure

version int(default 2) - Structure version number

returnCode int(default 0) - Return code from bridge

compCode int(default 0) - MQ completion code or CICS EIBRESP

reason int(default 0) - MQ reason or feedback code, or CICS EIBRESP2

UOWControl int(default 273) - Unit-of-work control

waitInterval int(default -2) - Wait interval for MQGET call issued by bridge task

linkType int(default 1) - Link type

facilityKeepTime int(default 0) - Bridge facility release time

ADSDescriptor int(default 0) - Send/receive ADS descriptor

conversationalTask int(default 0) - Whether task can be conversational

taskEndStatus int(default 0) - Status at end of task

facility byte[](default []) - Bridge facility token

'function string(default "") - field description

abendCode string(default "") - Abend code

authenticator string(default "") - Password or passticket

replyToFormat string(default "") - MQ format name of reply message

remoteSysId string(default "") - Remote CICS system Id to use

remoteTransId string(default "") - CICS RTRANSID to use

transactionId string(default "") - Transaction to attach

facilityLike string(default "") - Terminal emulated attributes

attentionId string(default "") - AID key

startCode string(default "") - Transaction start code

cancelCode string(default "") - Abend transaction code

nextTransactionId string(default "") - Next transaction to attach

inputItem int(default 0) - Reserved

ibm.ibmmq: MQIIH

Closed record

Header record representing the MQIIH structure.

Fields

flags int(default 0) - Flag of the header

encoding int(default 0) - Numeric encoding of data that follows NameValueString

strucId string(default "IIH ") - Structure identifier

strucLength int(default 84) - Length of the structure

version int(default 1) - Structure version number

codedCharSetId int(default 0) - Character set identifier of data that follows NameValueString

format string(default DEFAULT_BLANK_VALUE) - Format name of data that follows NameValueString

lTermOverride string(default DEFAULT_BLANK_VALUE) - The logical terminal override, placed in the IO PCB field

mfsMapName string(default DEFAULT_BLANK_VALUE) - The message format services map name, placed in the IO PCB field

replyToFormat string(default DEFAULT_BLANK_VALUE) - This is the MQ format name of the reply message that is sent in response to the current message

authenticator string(default DEFAULT_BLANK_VALUE) - The RACF® password or PassTicket

tranInstanceId byte[](default [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]) - This is the transaction instance identifier

tranState Char(default " ") - This indicates the IMS conversation state

commitMode Char(default "0") - IMS commit mode

securityScope Char(default "C") - This indicates the IMS security processing required

ibm.ibmmq: MQRFH

Closed record

Header record representing the MQRFH structure.

Fields

flags int(default 0) - Flag of the header

encoding int(default 0) - Numeric encoding of data that follows NameValueString

strucId string(default "RFH ") - Structure identifier

strucLength int(default 32) - Length of the structure

version int(default 1) - Structure version number

codedCharSetId int(default 0) - Character set identifier of data that follows NameValueString

format string(default DEFAULT_BLANK_VALUE) - Format name of data that follows NameValueString

nameValuePairs map<string>(default {}) - Related name-value pairs

ibm.ibmmq: MQRFH2

Closed record

Header record representing the MQRFH2 structure.

Fields

flags int(default 0) - Flag of the header

encoding int(default 273) - Numeric encoding of data that follows NameValueData

codedCharSetId int(default -2) - Character set identifier of data that follows NameValueData

folderStrings string[](default []) - Contents of the variable part of the structure

nameValueCCSID int(default 1208) - Coded character set for the NameValue data

nameValueData byte[](default []) - NameValueData variable-length field

nameValueLength int(default 0) - Length of NameValueData

format string(default DEFAULT_BLANK_VALUE) - Format name of data that follows NameValueData.The name should be padded with
blanks to the length of the field.

strucId string(default "RFH ") - Structure identifier

strucLength int(default 36) - Length of the structure

version int(default 2) - Structure version number

fieldValues table<MQRFH2Field>(default table []) - Table containing all occurrences of field values matching
the specified field name in the folder

ibm.ibmmq: MQRFH2Field

Closed record

Record defining a field in the MQRFH2 record.

Fields

folderreadonly string - The name of the folder containing the field

'fieldreadonly string - The field name

value boolean|byte|byte[]|float|int|string - The field value

ibm.ibmmq: Property

Closed record

Represents an IBM MQ message property.

Fields

descriptor map<int>? - Property descriptor

value boolean|byte|byte[]|float|int|string - Property value

ibm.ibmmq: QueueManagerConfiguration

Closed record

IBM MQ queue manager configurations.

Fields

name string - Name of the queue manager

host string - IBM MQ server host

port int(default 1414) - IBM MQ server port

channel string - IBM MQ channel

userID string? - IBM MQ userId

password string? - IBM MQ user password

secureSocket SecureSocket? - Configurations related to SSL/TLS encryption

sslCipherSuite SslCipherSuite? - Defines the combination of key exchange, encryption, and integrity algorithms used for establishing a secure SSL/TLS connection

ibm.ibmmq: SecureSocket

Closed record

Configurations for secure communication with the IBM MQ server.

Fields

cert TrustStore|string - Configurations associated with crypto:TrustStore or single certificate file that the client trusts

key KeyStore|CertKey? - Configurations associated with crypto:KeyStore or combination of certificate and private key of the client

provider string? - Name of the security provider used for SSL connections. The default value is the default security provider of the JVM

Errors

ibm.ibmmq: Error

Distinct

ErrorDetails

Represents a IBM MQ distinct error.

Object types

ibm.ibmmq: Destination

Distinct

IBM MQ destination client type.

put

Remote Function

function put(Message message) returns Error?

Parameters

message Message -

get

Remote Function

function get(*GetMessageOptions getMessageOptions) returns Message|Error?

Parameters

getMessageOptions *GetMessageOptions -

close

Remote Function

function close() returns Error?

Union types

ibm.ibmmq: OPEN_TOPIC_OPTION

OPEN_AS_SUBSCRIPTION|OPEN_AS_PUBLICATION

OPEN_TOPIC_OPTION

Options which can be provided when opening an IBM MQ topic.

MQRFH2|MQRFH|MQCIH|MQIIH

Header

Header types that are provided in the IBM MQ message.

ibm.ibmmq: SslCipherSuite

SslCipherSuite

The SSL Cipher Suite to be used for secure communication with the IBM MQ server.

Import

import ballerinax/ibm.ibmmq;

Metadata

Released date: 5 months ago

Version: 0.1.3

License: Apache-2.0

Compatibility

Platform: java17

Ballerina version: 2201.8.0

Pull count

Total: 28

Current verison: 22

Weekly downloads

Source repository

Keywords

ibm-mq

Contributors

Other versions

0.1.3

0.1.2 0.1.1 0.1.0

Dependencies

ballerina/time/2.4.0 ballerina/crypto/2.5.0

Cookie policy

Delete policy

classes

clients

constants

records

errors

objectTypes

unionTypes

ballerinax/ibm.ibmmq Ballerina library

Overview

IBM MQ queue

Producer

Consumer

IBM MQ topic

Publisher

Subscriber

Classes

ibm.ibmmq: QueueManager

Constructor

accessQueue

Parameters

Return Type

accessTopic

Parameters

Return Type

disconnect

Clients

ibm.ibmmq: Queue

put

Parameters

Return Type

get

Parameters

Return Type

close

Return Type

ibm.ibmmq: Topic

put

Parameters

Return Type

get

Parameters

Return Type

close

Return Type

Constants

ibm.ibmmq: ANY

ibm.ibmmq: MQGMO_ACCEPT_TRUNCATED_MSG

ibm.ibmmq: MQGMO_BROWSE_FIRST

ibm.ibmmq: MQGMO_BROWSE_MSG_UNDER_CURSOR

ibm.ibmmq: MQGMO_BROWSE_NEXT

ibm.ibmmq: MQGMO_CONVERT

ibm.ibmmq: MQGMO_FAIL_IF_QUIESCING

ibm.ibmmq: MQGMO_LOCK

ibm.ibmmq: MQGMO_MSG_UNDER_CURSOR

ibm.ibmmq: MQGMO_NO_SYNCPOINT

ibm.ibmmq: MQGMO_NO_WAIT

ibm.ibmmq: MQGMO_SYNCPOINT

ibm.ibmmq: MQGMO_UNLOCK

ibm.ibmmq: MQGMO_WAIT

ibm.ibmmq: MQOO_ALTERNATE_USER_AUTHORITY

ibm.ibmmq: MQOO_BIND_AS_Q_DEF

ibm.ibmmq: MQOO_BROWSE

ibm.ibmmq: MQOO_FAIL_IF_QUIESCING

ibm.ibmmq: MQOO_INPUT_AS_Q_DEF

ibm.ibmmq: MQOO_INPUT_EXCLUSIVE

ibm.ibmmq: MQOO_INPUT_SHARED

ibm.ibmmq: MQOO_OUTPUT

ibm.ibmmq: MQOO_PASS_ALL_CONTEXT

ibm.ibmmq: MQOO_PASS_IDENTITY_CONTEXT

ibm.ibmmq: MQOO_SET_ALL_CONTEXT

ibm.ibmmq: MQOO_SET_IDENTITY_CONTEXT

ibm.ibmmq: MQSO_CREATE

ibm.ibmmq: OPEN_AS_PUBLICATION

ibm.ibmmq: OPEN_AS_SUBSCRIPTION

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384

ibm.ibmmq: SSL_ECDHE_ECDSA_WITH_NULL_SHA