I’m running a below simple python MQ put/get program in my local machine that connects to a list of qmgrs running on a remote machine ‘qmgr.test.com’.
I’m getting MQRC 2009 error.
MQ Error for QMGR1: 2009 - FAILED: MQRC_CONNECTION_BROKEN
MQ Error for QMGR2: 2009 - FAILED: MQRC_CONNECTION_BROKEN
- connectivity between my local machine and mq host is good.(telnet to mq host and port is success)
- QMGR1 and QMGR2 are running fine.
- I was able to put/get message through ‘amqsputc’ command to the same
qmgrs and queue from my local. - MQ connection details are intact, i verified using print statement in
between code.
what could cause MQRC 2009 error?
import pymqi
import time
import logging
# Configuration details for IBM MQ
queue_managers = [
{
'queue_manager': 'QMGR1',
'channel': 'QMGR1.SVRCONN',
'queue_name': 'QMGR1.QUEUE',
'host': 'qmgr.test.com',
'port': '1441',
'user': 'mquser',
'password': '******'
},
{
'queue_manager': 'QMGR2',
'channel': 'QMGR2.SVRCONN',
'queue_name': 'QMGR2.QUEUE',
'host': 'qmgr.test.com',
'port': '1441',
'user': 'mquser',
'password': '******'
},
]
logging.basicConfig(filename="mq_health_check.log",level=logging.INFO)
def check_queue_manager_health(queue_manager_info, message):
qmgr = None
try:
# Connection info
conn_info = f"{queue_manager_info['host']}({queue_manager_info['port']})"
qmgr = pymqi.connect(queue_manager_info['queue_manager'],queue_manager_info['channel'],conn_info,queue_manager_info['user'],queue_manager_info['password'])
# open the queue
queue = pymqi.Queue(qmgr, queue_manager_info['queue_name'])
# Send the message
queue.put(message)
logging.info(f"Message sent to {queue_manager_info['queue_manager']} on {queue_manager_info['queue_name']}.")
# Retrieve the message
received_message = queue.get()
# check queue depth
queue_depth = queue.inquire(pymqi.CMQC.MQIA_CURRENT_Q_DEPTH)
logging.info(f"Queue Depth for {queue_manager_info['queue_manager']} on {queue_manager_info['queue_name']}: {queue_depth}")
queue.close()
except pymqi.MQMIError as e:
print(f"MQ Error for {queue_manager_info['queue_manager']}: {e.reason} - {e.errorAsString()}")
except Exception as e:
print(f"General Error for {queue_manager_info['queue_manager']}: {e.errorAsString()}")
finally:
if qmgr:
qmgr.disconnect()
if __name__ == "__main__":
# Message
message = "Test Message for monitoring"
# Send the message to each queue manager
for manager in queue_managers:
check_queue_manager_health(manager, message)
updating my question with error logs from mq client-
—– amqxufnx.c : 1446 ——————————————————- 10/16/24 15:58:21 – Process(15507.1) Program(Python)
Host(AB89548) Installation(MQNI93L22121400D)
VRMF(9.3.1.0)
Time(2024-10-16T20:58:21.725Z)
ArithInsert1(24948) ArithInsert2(2)
CommentInsert1(/opt/homebrew/lib64/libmqe_r.dylib)
CommentInsert2(No such file or directory)
CommentInsert3(64)
AMQ6174I: Failed to open catalog for error message id 0x6174, inserts: 24948, 2, /opt/homebrew/lib64/libmqe_r.dylib, No
such file or directory and 64. Issue "mqrc AMQ6174" on a different
system for a description of the message.
—– amqxufnx.c : 1446 ——————————————————-
You need to sign in to view this answers
Leave feedback about this