ibmmq-wrapper v0.1.0

ibmmq-wrapper

A light library-wrapper for ibmmq with easy interface.

Features

• configurable
• getting messages with processing in callback
• putting messages (commit/backout support)

Requirements

Installation

# Using NPM
$ npm install --save ibmmq-wrapper

# Using Yarn
$ yarn add ibmmq-wrapper

Usage

import * as IBMMQWrapper from 'ibmmq-wrapper';
//or
const IBMMQWrapper = require('ibmmq-wrapper');

//Pass your queue's params
const fooQueue = new IBMMQWrapper(connName, channelName, queueManager, queueName);

// Getting msg
fooQueue.getMessages((err, msg) => {
  if (err) {
    console.log(err);
  }
  console.log(msg);
});

// Getting msg with options
const getOpts = {
  options: ['MQGMO_NO_SYNCPOINT', 'MQGMO_WAIT'],
  matchOptions: 'MQMO_NONE',
  waitInterval: 'MQWI_UNLIMITED',
};

fooQueue.getMessages((err, msg) => {
  if (err) {
    console.log(err);
  }
  console.log(msg);
}, getOpts);

// Putting msg in queue
fooQueue.putMessage('test');

//Putting msg in queue with options
const putOpts = {
  options: ['MQPMO_NO_SYNCPOINT', 'MQPMO_NEW_MSG_ID', 'MQPMO_NEW_CORREL_ID'],
};

fooQueue.putMessage('new test', putOpts);

API

constructor(connName, channelName, queueManager, queueName)

getMessages(cb, opts)

putMessage(msg, opts)

Configuration

These are the available config options for:

• getMessages: https://www.ibm.com/support/knowledgecenter/SSB23S_1.1.0.2020/gtpc2/mqgmost.html
• putMessage: https://www.ibm.com/support/knowledgecenter/SSB23S_1.1.0.2020/gtpc2/mqpmost.html