IBM MQ Light Client Module
npm install mqlight-devMQ Light is designed to allow applications to exchange discrete pieces of
information in the form of messages. This might sound a lot like TCP/IP
networking, and MQ Light does use TCP/IP under the covers, but MQ Light takes
away much of the complexity and provides a higher level set of abstractions to
build your applications with.
This Node.js module provides the high-level API by which you can interact
with the MQ Light runtime.
See https://developer.ibm.com/messaging/mq-light/ for more details.
You will need a Node.js 4.x or newer runtime environment to use the MQ Light
API module. This can be installed from http://nodejs.org/download/, or by using
your operating system's package manager.
Install using npm:
``
npm install mqlight
`javascript`
var mqlight = require('mqlight-dev');
Then create some instances of the client object to send and receive messages:
`javascript
var recvClient = mqlight.createClient({service: 'amqp://localhost'});
var topicPattern = 'public';
recvClient.on('started', function() {
recvClient.subscribe(topicPattern);
recvClient.on('message', function(data, delivery) {
console.log('Recv: %s', data);
});
});
var sendClient = mqlight.createClient({service: 'amqp://localhost'});
var topic = 'public';
sendClient.on('started', function() {
sendClient.send(topic, 'Hello World!', function (err, data) {
console.log('Sent: %s', data);
sendClient.stop();
});
});
`
state.
* options - (Object) options for the client. Properties include:
* service, (String | Array | Function) (required) a String containing
the URL for the service to connect to, or alternatively an Array
containing a list of URLs to attempt to connect to in turn, or
alternatively an async function which will be expected to supply the
service URL(s) to a callback function that will be passed to it whenever
it is called (in the form function(err, service)). User names and
passwords may be embedded into the URL (for example, amqp://user:pass@host).
* id, (String, default: AUTO_[0-9a-f]{7}) (optional) a String, with a
maximum length of 256 characters, to serve as a unique identifier for this
client. A maximum of one instance of the client (as identified by the value
of this property) can be connected to an MQ Light server at a given point
in time. If another instance of the same client connects, then the
previously connected instance will be disconnected. This is reported, to
the first client, as a ReplacedError being emitted as an error event and
the client transitioning into stopped state. If the id property is not a
valid client identifier (for example, it contains a colon, it is too long,
or it contains some other forbidden character) then the function will throw
an InvalidArgumentError
* user, (String) (optional) user name for authentication.
Alternatively, the user name may be embedded in the URL passed via the
service property. If you choose to specify a user name via this property
and also embed a user name in the URL passed via the surface argument then
all the user names must match otherwise an InvalidArgumentError will be
thrown. User names and passwords must be specified together (or not at
all). If you specify just the user property but no password property an
InvalidArgumentError will be thrown.
* password, (String) (optional) password for authentication.
Alternatively, a password can be embedded in the URL passed via the service
property.
* sslKeystore, (String) (optional) SSL key store to use when authentication is
required for the MQ Light server and to authenticate the client with the
MQ Light server. A PKCS#12 format key store file is supported. Used only when
service specifies the amqps scheme. This option is mutually exclusive with the
'sslTrustCertificate', 'sslClientCerfiicate' and 'sslClientKey' options.
* sslKeystorePassphrase, (String) (optional) passphrase used to access the
SSL key store specified for the 'sslKeystore' option.
* sslTrustCertificate, (String) (optional) SSL trust certificate to use
when authentication is required for the MQ Light server. Used only when
service specifies the amqps scheme.
* sslClientCertificate, (String) (optional) SSL client certificate to use
when client authentication is required with the MQ Light server. Used only
when service specifies the amqps scheme.
* sslClientKey, (String) (optional) SSL client private key to use
when client authentication is required with the MQ Light server. Used only
when service specifies the amqps scheme.
* sslClientKeyPassphrase, (String) (optional) passphrase used to decrypt
the client private key specified for the 'sslClientKey' option.
* sslVerifyName, (Boolean, default: true) (optional) whether or not to
additionally check the MQ Light server's common name in the certificate
matches the actual server's DNS name.
* callback - (Function) (optional) callback that is invoked (indicating
success) if the client attains started state, or invoked (indicating
failure) if the client enters stopped state before attaining started
state. The callback function is supplied two arguments, the first being an
Error object that is set to null to indicate success. The second
is the instance of client, returned by mqlight.createClient, that the
callback relates to.
Returns a Client object representing the client instance. The client is an
event emitter and listeners can be registered for the following events:
started, stopped, restarted, error, drain, malformed and message.
$3
Prepares the client to send and/or receive messages from the server. As clients
are created in
starting state, this method need only be called if an instance
of the client has been stopped using the mqlight.Client.stop method.
* callback - (Function) (optional) callback to be notified when the client
has either: transitioned into (or was already in) started state; or has
entered stopped state before it can transition into started state. The
callback function will be invoked with a StoppedError as its argument if
the client transitions into a stopped state before it attains a started
state, which can happen as a result of calling the method.$3
Stops the client from sending and/or receiving messages from the server. The
client will automatically unsubscribe from all of the destinations that it is
subscribed to. Any system resources used by the client will be freed.
*
callback - (Function) (optional) callback to be notified when the client
has transitioned into stopped state.$3
Sends the value, specified via the
data argument to the specified topic.
String and Buffer values will be sent and received as-is. Other types will be
converted to JSON before sending and automatically parsed back from JSON when
received.*
topic - (String) the topic to which the message is sent.
A topic can contain any character in the Unicode character set.
* data - (String | Buffer | Object) the message body to be sent.
* options - (Object) (optional) additional options for the send operation.
Supported options are:
* qos, (Number) (optional) the quality of service to use when sending the
message. 0 is used to denote at most once (the default) and 1 is used for
at least once. If a value which is not 0 and not 1 is specified then this
method will throw a RangeError
* ttl, (Number) (optional) a time to live value for the message in
milliseconds. MQ Light will discard, without delivering, any
copy of the message that has not been delivered within its time to live
period. The value supplied for this argument must be greater than zero and
finite, otherwise a will be thrown when this method is called.
Refer to the server product documentation for the default and maximum
permitted time-to-live values.
* properties, (Object) (optional) a set of key/value properties that will
be carried alongside the message. Values must be non-null and one of the
following types: boolean, number, string or Buffer.
* callback - (Function) the callback argument is optional if the qos property
of the options argument is omitted or set to 0 (at most once). If the qos
property is set to 1 (at least once) then the callback argument is required
and a InvalidArgumentError is thrown if it is omitted. The callback will be
notified when the send operation completes and is passed the following
arguments:
* error, (Error) an error object if the callback is being invoked to
indicate that the send call failed. If the send call completes successfully
then the value null is supplied for this argument.
* topic, (String) the topic argument supplied to the corresponding
send method call.
* data, (Object) the data argument supplied to the corresponding
send method call.
* options, (Object) the options argument supplied to the corresponding
send method call.Returns
true if this message is sent, or is the next to be sent.Returns
false if the message is queued in user memory, due to either a
backlog of messages, or because the client was not in a connected state.
When the backlog of messages is cleared, the drain event will be sent.$3
Subscribes the client to a destination, based on the supplied
topicPattern
and arguments. The client throw a SubscribedError if a call is made
to client.subscribe(...) and the client is already associated with the
destination (as determined by the pattern and share arguments). It will throw
a StoppedError if the client has not been started prior to calling this
function.The
topicPattern argument is matched against the topic that messages are
sent to, allowing the messaging service to determine whether a particular
message will be delivered to a particular destination, and hence the
subscribing client.*
topicPattern - (String) used to match against the topic specified when a
message is sent to the messaging service. A pattern can contain any character
in the Unicode character set, with # representing a multilevel wildcard and
+ a single level wildcard. For more information, see
Wildcards.
* share - (String) (optional) name for creating or joining a shared
destination for which messages are anycast between connected subscribers. If
omitted, this defaults to a private destination (for example, messages can only be received
by a specific instance of the client).
* options - (Object) (optional) additional options for the subscribe
operation. Supported options are:
* autoConfirm, (Boolean) (optional) when set to true (the default) the
client will automatically confirm delivery of messages when all of the
listeners registered for the client's message event have returned.
When set to false, application code is responsible for confirming the
delivery of messages using the confirmDelivery method, passed via
the delivery argument of the listener registered for message events.
autoConfirm is only applicable when the qos property is set to 1. (The
qos property is described later.)
* credit, (Number) the maximum number of unconfirmed messages a client
can have before the server will stop sending new messages to the client
and require that it confirms some of the outstanding message deliveries in
order to receive more messages. The default for this property is 1024. If
specified, the value will be coerced to a Number and must be finite
and greater than, or equal to 0, otherwise a RangeError will be thrown.
* qos, (Number) the quality of service to use for delivering messages to
the subscription. Valid values are: 0 to denote at most once (the
default), and 1 for at least once. A RangeError will be thrown for other
value.
* ttl, (Number) a time-to-live value, in milliseconds, that is applied
to the destination that the client is subscribed to. If specified, the
value will be coerced to a Number, which must be finite and greater than, or equal to 0,
otherwise a RangeError will be thrown. This value will replace any
previous value, if the destination already exists. Time to live starts
counting down when there are no instances of a client subscribed to a
destination. It is reset each time a new instance of the client
subscribes to the destination. If time to live counts down to zero then MQ
Light will delete the destination by discarding any messages held at the
destination and not accruing any new messages. The default value for this
property is 0 - which means the destination will be deleted as soon as
there are no clients subscribed to it.
* callback - (Function) (optional) callback to be notified when the subscribe
operation completes. The callback function is passed the following
arguments:
* error, (Error) an error object if the callback is being invoked to
indicate that the subscribe call failed. If the subscribe call completes
successfully then the value null is supplied for this argument.
* topicPattern, (String) the topicPattern argument supplied to the
corresponding subscribe method call.
* share, (String) the share argument supplied to the corresponding
subscribe method call (or undefined if this parameter was not specified).Returns the
Client object that the subscribe was called on. message events
will be emitted when messages arrive.$3
Stops the flow of messages from a destination to this client. The client's
message callback will not longer be driven when messages arrive that match the
pattern associated with the destination. Messages may still be stored at the
destination if it has a non-zero time to live value or is shared and is
subscribed to by other clients instances. If the client is not subscribed to a
subscription, as identified by the optional pattern share arguments, then
this method will throw a
UnsubscribedError. The pattern and share arguments
will be coerced to type String. The pattern argument must be present
otherwise this method will throw a TypeError.*
topicPattern - (String) matched against the topicPattern specified on the
mqlight.Client.subscribe call to determine which destination the client will be
unsubscribed from.
* share - (String) (optional) matched against the share specified on the
mqlight.Client.subscribe call to determine which destination the client will be
unsubscribed from.
* options - (Object) (optional) properties that determine the behaviour of the
unsubscribe operation:
* ttl, (Number) (optional) sets the destination's time to live as part of
the unsubscribe operation. The default (when this property is not
specified) is not to change the destination's time to live. When specified
the only valid value for this property is 0.
* callback - (Function) (optional) callback to be notified when the
unsubscribe operation completes. The callback function is passed the
following arguments:
* error, (Error) an error object if the callback is being invoked to
indicate that the unsubscribe call failed. If the unsubscribe call
completes successfully then the value null is supplied for this
argument.
* topicPattern, (String) the topicPattern argument supplied to the
corresponding unsubscribe method call.
* share, (String) the share argument supplied to the corresponding
unsubscribe method call (or undefined if this parameter was not
specified).$3
Returns the identifier associated with the client. This will either be what
was passed in on the
Client.createClient call or an auto-generated id.$3
Returns the URL of the server to which the client is currently connected
to, or
undefined if not connected.$3
Returns the current state of the client, which will be one of the following states:
'starting', 'started', 'stopping', 'stopped', or 'retrying'.
$3
Emitted when a message is delivered from a destination matching one of the
client's subscriptions.
*
data - (String | Buffer | Object) the message body.
* delivery - (Object) additional information about why the event was sent.
Properties include:
* message, (Object) additional information about the message. Properties
include:
* topic, (Object) the topic that the message was sent to.
* confirmDelivery, (Function) a method that can be used to confirm
(settle) the delivery of a "at least once" quality of service (qos:1)
message. This method accepts an optional callback function as its
argument, which will be notified when the confirmation has completed
successfully. This property will only be present if the message was
delivered due to a subscribe call that specified both qos: 1 and
autoConfirm: false options.
* ttl, (Number) the remaining time to live period for this message in
milliseconds. This is calculated by subtracting the time the message
spends at an MQ Light destination from the time to live value specified
when the message is sent to IBM MQ Light.
* properties, (Object) if defined, a set of key/value properties that
were attached to the message.
* destination, (Object) collects together the values that the client
specified when it subscribed to the destination from which the message
was received.
* topicPattern, (String) the topic specified when the client subscribed
to the destination from which the message was received.
* share, (String) the share name specified when the client subscribed
to the destination from which the message was received. This property
will not be present if the client subscribed to a private destination.$3
This event is sent when a client attains the
started state by successfully
establishing a connection to the MQ Light server. The client is ready to send
messages. The client is also ready to receive messages by subscribing to topic
patterns.$3
This event is sent when a client attains the
stopped state as a result of the
mqlight.Client.stop method being invoked. In this state the client will not
receive messages, and attempting to send messages or subscribe to topic patterns
will result in an error being thrown from the respective method call.$3
Sent when an error is detected that prevents or interrupts a client's
connection to the messaging server. The client will automatically try to
reestablish connectivity unless either successful or the client is stopped by a
call to the
mqlight.Client.stop method. error events will periodically be
emitted for each unsuccessful attempt the client makes to reestablish
connectivity to the MQ Light server.*
error (Error) the error.$3
This event is sent when the client has reestablished connectivity to the MQ
Light server. The client will automatically re-subscribe to any destinations
that it was subscribed to prior to losing connectivity. Any send or subscribe
requests made while the client was not connected to the MQ Light server will
also be automatically forwarded when connectivity is reestablished.
$3
Sent to indicate that the client has flushed any buffered messages to the
network. This event can be used in conjunction with the value returned by the
mqlight.Client.send method to efficiently send messages without buffering a
large number of messages in memory allocated by the client.Errors
$3
This is a subtype of
Error defined by the MQ Light client. It is considered
a programming error. The underlying causes for this error are the parameter
values passed into a method. Typically InvalidArgumentError is thrown
directly from a method where TypeError and RangeError do not adequately
describe the problem (for example, you specified a client id that contains a colon).
InvalidArgumentError may also arrive asynchronously if, for example, the
server rejects a value supplied by the client (for example, a message time to live
value which exceeds the maximum value that the server will permit).$3
This is a subtype of
Error defined by the IBM MQ Light client. It is considered
an operational error. NetworkError is passed to an application if the
client cannot establish a network connection to the MQ Light server, or if an
established connection is broken.$3
This is a subtype of
Error defined by the IBM MQ Light client. It is considered
an operational error. NotPermittedError is thrown to indicate that a
requested operation has been rejected because the remote end does not permit
it.$3
This is a built-in subtype of
Error. It is considered a programming error.
The MQ Light client throws RangeError from a method when a numeric value
falls outside the range accepted by the client.$3
This is a subtype of
Error defined by the MQ Light client. It is considered
an operational error. ReplacedError is thrown to signify that an instance
of the client has been replaced by another instance that connected specifying
the exact same client id. Applications should react to ReplacedError by
ending as any other course of action is likely to cause two (or more) instances
of the application to loop replacing each other.$3
This is a subtype of
Error defined by the MQ Light client. It is considered
an operational error. SecurityError is thrown when an operation fails due
to a security related problem. Examples include:* The client specifies an incorrect user name and password combination.
* The client specifies a user name and password but the server is not configured to
require a user name and password.
* The client is configured to use an SSL/TLS certificate to establish the
identity of the server, but cannot.
$3
This is a subtype of
Error defined by the MQ Light client. It is considered
a programming error - but is unusual in that, in some circumstances, a client
may reasonably expect to receive StoppedError as a result of its actions
and would typically not be altered to avoid this condition occurring.
StoppedError is thrown by methods which require connectivity to the server
(for example, send or subscribe) when they are invoked while the client is in stopping or
stopped states. StoppedError is also supplied to the callbacks and supplied
to methods which require connectivity to the server, when the client
transitions into stopped state before it can perform the action. It is this
latter case where applications may reasonably be written to expect
StoppedError.$3
This is a subtype of
Error defined by the MQ Light client. It is considered
a programming error. SubscribedError is thrown from the
client.subscribe(...) method call when a request is made to subscribe to a
destination that the client is already subscribed to.$3
This is a built-in subtype of
Error. It is considered a programming error.
The MQ Light client throws TypeError if the type of a method argument
cannot be coerced to the type expected by the client code. For example
specifying a numeric constant instead of a function. TypeError is also used
when a required parameter is omitted (the justification being that the argument
is assigned a value of undefined, which isn't the type that the client is
expecting).$3
This is a subtype of
Error defined by the MQ Light client. It is considered
a programming error. UnsubscribedError is thrown from the
client.unsubscribe(...) method call when a request is made to unsubscribe
from a destination that the client is not subscribed to.Client state machine
Each instance of a client (as returned from
mqlight.createClient(...) is
backed by the following state machine:Each of the states shown in the state machine diagram corresponds to the values
stored in the
mqlight.Client.state property, with the exception of retrying1
and which are collapsed into a single retrying value. While in the
retrying state, the client will wait for up approximately 60 seconds (based on
an exponential backoff algorithm) before attempting to transition into a new
state.Each line shown in the state machine diagram represents a possible way in which
the client can transition between states. The lines are labelled with
information about the transitions, which includes:
1. The function calls that can cause the transition to occur:
*
start() corresponds to the mqlight.Client.start function.
* stop() corresponds to the mqlight.Client.stop function.
2. Change that occur at the network level, which can cause the transition to
occur. For example:
* [broken] occurs when an established network connection between the client
and the server is interrupted.
* [connected] occurs when the client successfully establishes a network
connection to the server.
* [failed] occurs when the client unsuccessfully attempts to establish a
network connection to the server.
3. Events that are emitted. Specifically:
* indicates that an error event is sent.
* indicates that a restarted event is sent.
* indicates that a started event is sent.
* indicates that a stopped event is sent.
Samples
To run the samples, install the module via npm and navigate to the
mqlight/samples/ folder.Usage:
Receiver Example:
`
Usage: recv.js [options]Options:
-h, --help show this help message and exit
-s URL, --service=URL service to connect to, for example:
amqp://user:password@host:5672 or
amqps://host:5671 to use SSL/TLS
(default: amqp://localhost)
-c FILE, --trust-certificate=FILE
use the certificate contained in FILE (in PEM format) to
validate the identity of the server. The connection must
be secured with SSL/TLS (e.g. the service URL must start
with 'amqps://')
-t TOPICPATTERN, --topic-pattern=TOPICPATTERN
subscribe to receive messages matching TOPICPATTERN
(default: public)
-i ID, --id=ID the ID to use when connecting to MQ Light
(default: recv_[0-9a-f]{7})
--destination-ttl=NUM set destination time-to-live to NUM seconds
-n NAME, --share-name NAME
optionally, subscribe to a shared destination using
NAME as the share name
-f FILE, --file=FILE write the payload of the next message received to
FILE (overwriting previous file contents) then end.
(default is to print messages to stdout)
-d NUM, --delay=NUM delay for NUM seconds each time a message is received.
--verbose print additional information about each message
received
Sender Example:
Usage: send.js [options] ... Options:
-h, --help show this help message and exit
-s URL, --service=URL service to connect to, for example:
amqp://user:password@host:5672 or
amqps://host:5671 to use SSL/TLS
(default: amqp://localhost)
-c FILE, --trust-certificate=FILE
use the certificate contained in FILE (in PEM format) to
validate the identity of the server. The connection must
be secured with SSL/TLS (e.g. the service URL must start
with 'amqps://')
-t TOPIC, --topic=TOPIC
send messages to topic TOPIC
(default: public)
-i ID, --id=ID the ID to use when connecting to MQ Light
(default: send_[0-9a-f]{7})
--message-ttl=NUM set message time-to-live to NUM seconds
-d NUM, --delay=NUM add NUM seconds delay between each request
-r NUM, --repeat=NUM send messages NUM times, default is 1, if
NUM <= 0 then repeat forever
--sequence prefix a sequence number to the message
payload (ignored for binary messages)
-f FILE, --file=FILE send FILE as binary data. Cannot be
specified at the same time as
Feedback
You can help shape the product we release by trying out the beta code and
leaving your feedback.
$3
If you think you've found a bug, please leave us
feedback.
To help us fix the bug a log might be helpful. You can get a log by setting the
environment variable
to debug and by collecting the output
that goes to stderr when you run your application.Release notes
$3
* Maintenance release
* Fixes for Node 9.x / 10.x API compatibility
* Bump version of moment to resolve CVEs
$3
* Bugfix for issues around delivery confirmation and link credit policies.
$3
* Support for Node.js 6.x.x engine.
* Complete rewrite of the client to use a pure JavaScript implementation of the
AMQP 1.0 protocol. Hence we no longer require compilation of a native addon
and can more easily support newer releases of the Node.js runtime.
* This is considered a major semver bump.
$3
* Bugfix for issues around network retries of the http service lookup function
$3
* Bugfix ProtonMessage destructor causes fatal error during trace
$3
* Support for Node.js 5.x.x engine.
* Bugfix client state not set to retrying after recoverable connection break
* Bugfix re-subscribing to destination fails after calling client stop followed
by client start
$3
* Bugfix to prevent connection aborted and/or SASL authentication failures
if client was manually stopped and then started.
$3
* Support for Node.js 4.2.x LTS engine.
$3
* Allow client identifiers up to 256 characters in length.
* Bugfix for sslVerifyName on Node.js 0.12.x.
* Bugfix for ffdcs and errors when connecting before the MQ Light server has
started.
$3
* Bugfix to prevent
message.delivery.topic returning an absolute address when
using a secure (amqps) connection.$3
* Added support for sending and receiving messages with custom properties.
* Added optional callback to confirmDelivery function.
* Bugfix to prevent qos=0 send callback being called early.
* Support for Node.js 0.12.x engine.
$3
* Dependency on OpenSSL libraries removed.
* Improvements to async method completion logic.
* Minor fix to mqlight-log.js.
$3
* First official release.
* Support for supplying time-to-live options when sending a message or creating
a destination.
* Support for unsubscribing from an existing destination.
* Support flow control for sending applications by having the
send method
return a boolean value to indicate when data is being buffered and have the
client emit a drain event when all buffered data has been written.
* Support passing authentication details as user:pass@host service URIs.
* API changes based on user feedback to rename connect -> start,
disconnect -> stop, to make createClient` return an already started* Second beta release.
* Support for Mac OS X.
* Support for sending and receiving 'at-least-once' messages either with
automatic or manual confirmation by the receiver.
* Updated samples to use service/topic arguments instead of address.
* Initial beta release.
* Support for sending and receiving 'at-most-once' messages.
* Support for wildcard subscriptions.
* Support for shared subscriptions.