ibmmq-facade

IBMMQ FACADE

A high abstraction facade to the ibmmq library.

Installation

npm install --save ibmmq-facade

Examples

Connecting to our queue manager and queue

const {queueManagerConnector, queueConnector, Queue} = require('ibmmq-facade');

const config = {
  host: 'localhost',
  port: 1750,
  user: 'user',
  password: 'password',
  queueManagerName: 'qMgr',
  channelName: 'chName'
};

(async function() {
  try {
    // returns the queue manager handle object which must be passed in when connecting a queue
    const qmHandle = await queueManagerConnector.connect(config);

    const queueName = 'MY_QUEUE';
    // returns a queue handle which must be passed to your queue data structure
    // when retrieving or sending messages
    const queueHandle = await queueConnector.connect(qmHandle, queueName);
  } catch (error) {
    return false;
  } finally {
    queueConnector.clean();
    queueManagerConnector.clean();
  }
})

Getting messages from queue

// this buffer can be any integer lower than the queue managers max message length (in bytes)
// if you know the size of data on a queue, it is best to set this manually
// if you are unsure, then set it to queue managers the max message length
const buffer = queueManagerConnector.getConnectionOptions().ClientConn.MaxMsgLength;
const queue = new Queue(queueHandle, buffer);

while (queue.isMessages()) {
  const message = queue.dequeue();

  // do something with the message contents?
  console.log(message);
}

Putting messages on to a local queue

const queueHandle = queueConnector.connect(queueManagerConnector.getHandle(), 'QUEUE_NAME');
const queue = new Queue(queueHandle);

const message = "Hello World";
queue.enqueue(message);

Putting messages on to a remote queue

const queueHandle = queueConnector.connect(queueManagerConnector.getHandle(), 'QUEUE_NAME', true); // true to allow posting to remote queue
const queue = new Queue(queueHandle);

const message = "Hello World";
queue.enqueue(message);

Public methods

QueueManagerConnector

• QueueManager::isConfigValid(configObject) : bool
• QueueManager::connect(configObject) : object
• QueueManager::getHandle() : object
• QueueManager::clean()

QueueConnector

• QueueConnector::getQueueOptions() : object
• QueueConnector::connect(queueManagerHandle, queueName [, isRemoteQueue]) : object
• QueueConnector::getHandle() : object
• QueueConnector::clean()

Queue

• Queue::__construct(queueHandle [, buffer])
• Queue::dequeue() : buffer
• Queue::enqueue(message)
• Queue::isMessages() : bool
• Queue::peek() : object