This shows you the differences between two versions of the page.
en:mq_series_adaptor [2023/05/08 12:03] montse [Functions] |
— (current) | ||
---|---|---|---|
Line 1: | Line 1: | ||
- | ======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 fisrt out.\\ | ||
- | |||
- | |||
- | ===== Configuration ===== | ||
- | |||
- | In the initialisation process, it is necessary to provide the information to connect to the queue. This is the information that the adapter 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 to permanent change. | ||
- | |||
- | * **connect**: Attempts to connect to the specified queue. Returns true if successful, and returns false or error if unsuccessful. No parameters are required since it uses the adapter's parameters. | ||
- | |||
- | * **disconnect**: Performs disconnection from 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 for rollback. | ||
- | |||
- | * **sendMessage**: Send messages to the queue. You must indicate in the parameters which message the queue has to receive. | ||
- | |||