Просмотр новых публикаций

Проблема при чтении сообщения из MQ

Автор ClaudiusVile, 28 апр 2018 14:08

Авторизуйтесь для ответа в теме

Сообщений в теме: 2

#1 ClaudiusVile

Новый участник

Members
3 сообщений

Отправлено 28 апреля 2018 - 14:08

Здравствуйте.

Во время тестирования приложения, использующего mq-очереди, возникла следующая проблема.

Каждый новый тред успешно подключается к входящей и исходящей очередям, отправляет и считывает сообщение в первой итерации, но начиная со второй итерации только отправляет, а при чтении получает ошибку 2033 "Сообщение не найдено". В то же время в исходящей очереди появляется никем не считанное сообщение.

Я использую groovy-скрипт для отправки/чтения, аналогичный алгоритм проверялся на HP LR и была получена та же ошибка.

Скрипт прилагаю ниже:
Init-блок

Скрытый текст

import com.ibm.mq.*;

import java.util.*;
import java.nio.file.Files;
import java.nio.file.Paths;

class QueueController{
// параметры для подключения к MQ`
public String inputMgrName;
public String outputMgrName;
public String putQueueName;
public String getQueueName;
public String msgBody;

// менеджер и очереди
public MQQueueManager inputMgr;
public MQQueueManager outputMgr;
public MQQueue getQueue;
public MQQueue putQueue;

public MQPutMessageOptions pmo = new MQPutMessageOptions();
public MQGetMessageOptions gmo = new MQGetMessageOptions();
public MQMessage requestMsg = new MQMessage();
public MQMessage responseMsg = new MQMessage();

// queueMgrName - имя менеджера MQ
// putQueueName - имя очереди входящих сообщений
// getQueueName - имя очереди исходящих сообщений
// msgBody - тело сообщения
public QueueController(String inputMgrName, String outputMgrName, String putQueueName, String getQueueName, String msgBody){
this.inputMgrName = inputMgrName;
this.outputMgrName = outputMgrName;
this.putQueueName = putQueueName;
this.getQueueName = getQueueName;
this.msgBody = msgBody;

// параметры MQ enviroment - могут быть заменены
MQEnvironment.hostname="host";
MQEnvironment.port=port;
MQEnvironment.channel = "SYSTEM.ADMIN.SVRCONN";
MQEnvironment.userID = "user";
MQEnvironment.password = "password";

this.inputMgr = new MQQueueManager(inputMgrName);
this.putQueue = inputMgr.accessQueue(putQueueName, MQC.MQOO_BIND_NOT_FIXED | MQC.MQOO_OUTPUT);

MQEnvironment.hostname="host";
MQEnvironment.port=port;
this.outputMgr = new MQQueueManager(outputMgrName);
this.getQueue = outputMgr.accessQueue(getQueueName, MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT);

//this.gmo.options = MQC.MQGMO_ALL_MSGS_AVAILABLE;
this.gmo.options = MQC.MQGMO_WAIT;
this.gmo.waitInterval = ${wait_interval};

initialRequestAndResponseMessage();

}

// дополнительные настройки для MQ сообщения
public void initialRequestAndResponseMessage(){
requestMsg.clearMessage();
responseMsg.clearMessage();
requestMsg.replyToQueueName = getQueueName;
requestMsg.report=MQC.MQRO_PASS_MSG_ID;
requestMsg.format = MQC.MQFMT_STRING;
requestMsg.messageType=MQC.MQMT_REQUEST;

requestMsg.writeString(msgBody);
}
}

String msg = new String(Files.readAllBytes(Paths.get("X:/xxxx/xxxxxxx/File.xml")));
QueueController queueController = new QueueController("QM", "QM", "Q1", "Q2", msg);
vars.putObject('queueController',queueController);

Action-блок

Скрытый текст

0

Наверх

#2 ClaudiusVile

Новый участник

Members
3 сообщений

Отправлено 21 мая 2018 - 12:45

UPDATE: Более детальное изучение ошибки привело к тому, что виновником оказалась ошибка установления tcp/ip с менеджером очередей mq (mq error code 9208), из-за которой менеджер блокирует все попытки получения сообщения после первого. В спойлере лог проблемы. Проблема все еще не устранена.

Настройки tcp connection keepAlive на генераторе, сервере и самом менеджере не дали результата.

Скрытый текст