Skip to main content

MQ Series Adaptor

Introduction

This adaptor is used to connect with a MQ console to be able to work with a huge amount of data. MQ queues are data structure that follow the FIFO (First in, First out) philosophy, first message in first out.

Configuration

In the initialization process, it is necessary to provide the information to connect to the queue. This is the information that the adaptor needs:

Initialization Parameters

  • Queue name: name of the queue to connect.
  • Queue manager: queue manager name.
  • Channel name: channel name.
  • Host: IP address of the queue console.
  • Port: port for the IP address of the queue console.
  • User: username to access the MQ console.
  • Password: password to access the MQ console.
  • Message selector: option to choose a specific message.
  • Queue type: type of queue to be connected. For example: Sender (Receives messages) or Receiver (Sends messages).

Functions

  • addConsumer: adds a new consumer to the queue.
  • commit: confirmation of a temporary change to permanent.
  • connect: attempts to connect to the specified queue. Returns true if it succeeds, and returns false or error if it fails.No parameters are required since it uses the adapter's parameters.
  • disconnect: performs the disconnection of the queue. Returns true if successful or false otherwise. No parameters are required.
  • getNumMessages: only for QUEUE_SENDER. Returns the number of messages contained in a queue.
  • receiveMessage: it reads and receives all the messages sent to a queue. The first message received would be stored in the first position and the last one in the last position.
  • rollback: allows rollback.
  • sendMessage: send messages to the queue. You must indicate in the parameters which message the queue has to receive.