-
Notifications
You must be signed in to change notification settings - Fork 41
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'feature/ts-types' of github.com:asselin/mq-mqi-nodejs i…
…nto asselin-feature/ts-types
- Loading branch information
Showing
10 changed files
with
850 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,122 @@ | ||
/* | ||
Copyright (c) IBM Corporation 2017 | ||
Licensed under the Apache License, Version 2.0 (the "License"); | ||
you may not use this file except in compliance with the License. | ||
You may obtain a copy of the License at | ||
http://www.apache.org/licenses/LICENSE-2.0 | ||
Unless required by applicable law or agreed to in writing, software | ||
distributed under the License is distributed on an "AS IS" BASIS, | ||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
See the License for the specific language governing permissions and | ||
limitations under the License. | ||
Contributors: | ||
Mark Taylor - Initial Contribution | ||
Andre Asselin - Typescript conversion | ||
*/ | ||
|
||
/* | ||
* This is an example of a Node.js program to inquire about the attributes of an IBM MQ | ||
* object. | ||
* | ||
* The queue manager name can be given as a parameter on the | ||
* command line. Defaults are coded in the program. | ||
* | ||
*/ | ||
|
||
// Import the MQ package | ||
import * as mq from "ibmmq"; | ||
import { MQC } from "ibmmq"; // Want to refer to this export directly for simplicity | ||
|
||
// The queue manager to be used. This can be overridden on command line. | ||
let qMgr = "QM1"; | ||
|
||
function formatErr(err: Error) { | ||
return "MQ call failed in " + err.message; | ||
} | ||
|
||
|
||
// When we're done, close queues and connections | ||
function cleanup(hConn: mq.MQQueueManager, hObj: mq.MQObject) { | ||
mq.Close(hObj, 0, function (closeErr) { | ||
if (closeErr) { | ||
console.log(formatErr(closeErr)); | ||
} else { | ||
console.log("MQCLOSE successful"); | ||
} | ||
mq.Disc(hConn, function (discErr) { | ||
if (discErr) { | ||
console.log(formatErr(discErr)); | ||
} else { | ||
console.log("MQDISC successful"); | ||
} | ||
}); | ||
}); | ||
} | ||
|
||
// This is where the interesting work is done. See MQ Knowledge Center documentation | ||
// about the MQINQ verb to understand more about what this is doing, and how the | ||
// parameters work. | ||
function inqQmgr(hObj: mq.MQObject) { | ||
// We will request 3 attributes of the queue manager. | ||
const selectors = [new mq.MQAttr(MQC.MQCA_Q_MGR_NAME), | ||
new mq.MQAttr(MQC.MQCA_DEAD_LETTER_Q_NAME), | ||
new mq.MQAttr(MQC.MQIA_CODED_CHAR_SET_ID) | ||
]; | ||
|
||
try { | ||
mq.Inq(hObj,selectors); | ||
|
||
console.log("ccsid=%d qmgrName = \"%s\", dlqName = \"%s\"",selectors[2].value,selectors[0].value,selectors[1].value); | ||
|
||
|
||
} catch (err) { | ||
const mqerr = err as mq.MQError; | ||
console.log(mqerr); | ||
} | ||
} | ||
|
||
// The program really starts here. | ||
// Connect to the queue manager. If that works, the callback function | ||
// opens the queue manager for inquiry, and then we can do the real query. | ||
|
||
console.log("Sample AMQSINQ.JS start"); | ||
|
||
// Get command line parameters | ||
const myArgs = process.argv.slice(2); // Remove redundant parms | ||
if (myArgs[0]) { | ||
qMgr = myArgs[0]; | ||
} | ||
|
||
const cno = new mq.MQCNO(); | ||
cno.Options = MQC.MQCNO_NONE; | ||
|
||
mq.Connx(qMgr, cno, function(connErr,hConn) { | ||
if (connErr) { | ||
console.log(formatErr(connErr)); | ||
} else { | ||
console.log("MQCONN to %s successful ", qMgr); | ||
|
||
// Define what we want to open, and how we want to open it. | ||
// In this case, we want to INQUIRE on attributes of the queue manager so we | ||
// get an object handle that refers to that qmgr. | ||
// No ObjectName is needed for this inquiry - the fact that it is the Q_MGR type | ||
// is sufficient. | ||
const od = new mq.MQOD(); | ||
od.ObjectName = null; | ||
od.ObjectType = MQC.MQOT_Q_MGR; | ||
const openOptions = MQC.MQOO_INQUIRE; | ||
mq.Open(hConn,od,openOptions,function(openErr,hObj) { | ||
if (openErr) { | ||
console.log(formatErr(openErr)); | ||
} else { | ||
console.log("MQOPEN of queue manager successful"); | ||
inqQmgr(hObj); | ||
} | ||
cleanup(hConn,hObj); | ||
}); | ||
} | ||
}); |
Oops, something went wrong.